docs • 教程 • 第二个流程

创建你的第二个流程

概述

本教程基于第一个教程，创建一个流程，开始从外部源引入数据以在本地执行有用操作。

该流程将：

定期从网站检索信息
将该信息转换为有用的形式
在调试侧边栏中显示结果

1. 添加一个Inject节点

在上一教程中，Inject节点被用于在点击其按钮时触发流程。在本教程中，Inject节点将被配置为按固定间隔触发流程。

从面板中将Inject节点拖放到工作区。

双击节点打开编辑对话框。将重复间隔设置为every 5 minutes。

点击完成关闭对话框。

2. 添加一个HTTP请求节点

HTTP请求节点可在触发时用于获取网页。

将智能体添加到工作区后，编辑它以将URL属性设置为：

https://earthquake.usgs.gov/earthquakes/feed/v1.0/summary/significant_month.csv

然后点击"完成"关闭对话框。

该URL是美国地质调查局网站上提供的最近一个月重大地震数据源。该网站还提供了一些其他选项，您可以在完成本教程后尝试使用。

3. 添加CSV节点

添加一个CSV节点并编辑其属性。启用"首行包含列名"选项。

然后点击完成关闭。

4. 添加一个调试节点

在输出端添加一个Debug节点。

5. 将所有组件连接起来

添加连线连接：

Inject节点输出到HTTP Request节点输入。
HTTP请求节点的输出连接到CSV节点的输入。
CSV节点的输出连接到Debug节点的输入。

6. 添加一个Switch节点

在工作区添加一个Switch节点。编辑其属性并配置为检查属性msg.payload.mag，测试条件设为>=，将其更改为测试number类型且值为7。点击完成关闭。

从CSV节点添加第二条连线到这个Switch节点。

7. 添加一个变更节点

添加一个Change节点，连接到Switch节点的输出端。将其配置为将msg.payload设置为字符串PANIC!。

8. 添加调试节点

将一个新的调试节点连接到变更节点的输出端

9. 部署

点击部署按钮将流程部署到运行时环境。

打开调试侧边栏选项卡，点击注入按钮。您应该会看到一个条目列表，其中包含类似以下内容：

msg.payload : Object
{"time":"2017-11-19T15:09:03.120Z","latitude":-21.5167,"longitude":168.5426,"depth":14.19,"mag":6.6,"magType":"mww","gap":21,"dmin":0.478,"rms":0.86,"net":"us","id":"us2000brgk","updated":"2017-11-19T17:10:58.449Z","place":"68km E of Tadine, New Caledonia","type":"earthquake","horizontalError":6.2,"depthError":2.8,"magError":0.037,"magNst":72,"status":"reviewed","locationSource":"us","magSource":"us"}

现在您可以点击每个属性左侧的小箭头展开它们，查看其中的内容

如果发生震级大于7级的地震，您还将看到如下调试信息：

msg.payload : string(6)
"PANIC!"

你可以将开关值7改为更小的数值来测试程序。修改后记得点击部署按钮。

概述

该流程每5分钟自动触发一次，从指定URL获取数据。它会解析数据并在调试侧边栏中显示。同时，它会检查数据中的震级数值，并对震级大于或等于7的消息进行流程分支处理。此类消息的有效载荷会被修改并显示在调试侧边栏中。

源

本教程创建的流程由以下json表示。要将其导入编辑器，请复制到剪贴板，然后粘贴到导入对话框中。

[{"id":"e36406f2.8ef798","type":"inject","z":"f03b57d5.e525f8","name":"","topic":"","payload":"","payloadType":"str","repeat":"300","crontab":"","once":false,"x":130,"y":900,"wires":[["c3c50023.3bbed"]]},{"id":"c3c50023.3bbed","type":"http request","z":"f03b57d5.e525f8","name":"Recent Quakes","method":"GET","url":"https://earthquake.usgs.gov/earthquakes/feed/v1.0/summary/significant_month.csv","tls":"","x":300,"y":900,"wires":[["8afc6cac.e0812"]]},{"id":"8afc6cac.e0812","type":"csv","z":"f03b57d5.e525f8","name":"","sep":",","hdrin":true,"hdrout":"","multi":"one","ret":"\\n","temp":"","x":470,"y":900,"wires":[["44779781.4190f8","6f0eb546.9e208c"]]},{"id":"44779781.4190f8","type":"debug","z":"f03b57d5.e525f8","name":"","active":true,"complete":false,"x":630,"y":900,"wires":[]},{"id":"6f0eb546.9e208c","type":"switch","z":"f03b57d5.e525f8","name":"","property":"payload.mag","propertyType":"msg","rules":[{"t":"gte","v":"7","vt":"num"}],"checkall":"true","outputs":1,"x":510,"y":960,"wires":[["d78d4aa8.8c8208"]]},{"id":"d78d4aa8.8c8208","type":"change","z":"f03b57d5.e525f8","name":"","rules":[{"t":"set","p":"payload","pt":"msg","to":"PANIC!","tot":"str"}],"action":"","property":"","from":"","to":"","reg":false,"x":650,"y":1020,"wires":[["72fddece.fac0d"]]},{"id":"72fddece.fac0d","type":"debug","z":"f03b57d5.e525f8","name":"","active":true,"complete":false,"x":750,"y":960,"wires":[]}]