简介
node-red-contrib-azure-event-hub
是基于 Node.js 平台的 npm
包,是一个用于连接 Azure 事件中心(Event Hub)的 Node-RED 的扩展器。
连接到 Azure 事件中心后,我们就可以从其中接收实时事件数据。通过 Node-RED 可以方便地将这些接收到的事件流数据进行可视化处理,为数据分析提供有力的支持。
本篇文章将介绍如何安装和配置 node-red-contrib-azure-event-hub
插件,并提供相关示例代码。
安装
在命令行中执行以下代码来安装 node-red-contrib-azure-event-hub
插件:
npm install -g node-red-contrib-azure-event-hub
配置
配置 Azure 事件中心
在使用 node-red-contrib-azure-event-hub
插件之前,需要先将 Azure 事件中心设置好。这里假设我们已经有了一个 Azure 事件中心,其连接字符串如下:
Endpoint=sb://myeventhub.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=9999999999999999999
其中 myeventhub
就是我们要连接的事件中心名称,而 SharedAccessKeyName
和 SharedAccessKey
分别是连接字符串中用于认证的密钥对。
在 Node-RED 中配置 Azure 事件中心节点
启动 Node-RED 编辑器,在左侧节点工具栏中选择 Azure 事件中心节点,将其拖拽到编辑区中。在节点的配置菜单中,选择 “Add new azure event hub” 按钮,输入连接字符串和事件中心名称,如下图所示:
接收事件数据
在连接事件中心节点的下方添加一些用于处理事件数据的节点,例如 JSON 解析器、控制台记录节点等。如下图所示:
最终的 Node-RED 工作流如下:
示例代码
以下是使用 node-red-contrib-azure-event-hub
插件连接到 Azure 事件中心并接收数据的示例代码:
[{"id":"c6f4d6e0.6bfeb","type":"eventhub listener","z":"e5a87de1.416688","eventHub":"d0085b5f.1135","name":"myeventhub","x":270,"y":80,"wires":[["9dd9c25c.176f7"]]},{"id":"9dd9c25c.176f7","type":"json","z":"e5a87de1.416688","name":"","property":"payload","action":"","pretty":false,"x":420,"y":80,"wires":[["1626428c.e394ce"]]},{"id":"1626428c.e394ce","type":"debug","z":"e5a87de1.416688","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","x":570,"y":80,"wires":[]},{"id":"aa84c498.b9f9a","type":"inject","z":"e5a87de1.416688","name":"","props":[{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":130,"y":80,"wires":[["c6f4d6e0.6bfeb"]]},{"id":"d0085b5f.1135","type":"eventhub","host":"myeventhub.servicebus.windows.net","eventHubName":"myeventhub","sasKeyName":"RootManageSharedAccessKey","sasKey":"9999999999999999999","retryTimeout":"10","retryCount":"3"}]
结论
使用 node-red-contrib-azure-event-hub
插件,我们可以轻松地将 Azure 事件中心的实时事件数据导入到 Node-RED 平台中进行可视化处理,为我们的数据分析工作提供很好的帮助。如果您需要连接到 Azure 事件中心,这个插件将是您不错的选择。
来源:JavaScript中文网 ,转载请注明来源 https://www.javascriptcn.com/post/600566a881e8991b448e2dec