设置先决条件

安装

NeuronEX

因为 NeuronEX 版本中集成了 eKuiper,页面增加数据流处理板块,所以只需要安装 NeuronEX 版本。

  1. $ sudo docker pull emqx/neuronex:latest
  2. $ sudo docker run -d --name neuron -p 7000:7000 --privileged=true --restart=always emqx/neuronex:latest

分别安装 Neuron 和 eKuiper

用户可以选择将 Neuorn 和 eKuiper 分开安装,可用 docker-compose 直接安装及配置,docker-compose.yml 示例如下所示,安装的版本可根据需求自行选择。

  1. version: '3.4'
  2. services:
  3. ekuiper-manager:
  4. image: emqx/ekuiper-manager:1.5.0
  5. container_name: ekuiper-manager
  6. ports:
  7. - "9082:9082"
  8. ekuiper:
  9. image: lfedge/ekuiper:1.5.1-slim
  10. hostname: ekuiper
  11. container_name: ekuiper
  12. ports:
  13. - "9081:9081"
  14. - "127.0.0.1:20498:20498"
  15. environment:
  16. MQTT_SOURCE__DEFAULT__SERVER: tcp://broker.emqx.io:1883
  17. KUIPER__BASIC__CONSOLELOG: "true"
  18. KUIPER__BASIC__IGNORECASE: "false"
  19. volumes:
  20. - nng-ipc:/tmp
  21. neuron:
  22. image: emqx/neuron:2.3.0
  23. hostname: neuron
  24. container_name: neuron
  25. ports:
  26. - "7000:7000"
  27. volumes:
  28. - nng-ipc:/tmp
  29. source:
  30. image: alpine/httpie
  31. container_name: httpie
  32. command:
  33. - --ignore-stdin
  34. - --check-status
  35. - ekuiper:9081/streams
  36. - sql=CREATE STREAM neuronStream() WITH (TYPE="neuron",FORMAT="json",SHARED="true");
  37. depends_on:
  38. - ekuiper
  39. - neuron
  40. volumes:
  41. nng-ipc:

执行成功后 Neuron 和 eKuiper 已分别启动。

登录 kuiper-manager。

  • 地址: http://$yourhost:9082
  • 用户名:admin
  • 密码:public

添加服务,如图所示。

ekuiper-service

提示

Endpoint 中的地址应填写启动 eKuiper 的本机地址。

添加服务完成后,因为 docker-compose 已经创建了一个数据流,所以在刚创建的服务中应当有一条 neuronStream 的流。

eKuiper 的具体使用操作可参考 ekuiper 控制台使用数据流处理 - 图2 (opens new window)

页面操作

数据流引擎中预先定义了一个名为 neuronStream 的数据流,其属性为neuron。用户需要订阅所需的南向设备数据组。订阅的数据组将成为流引擎的数据流。流引擎中的所有规则都将共享此数据流。

第一步,查看数据流处理应用节点

当用户安装 .deb 或 .rpm Neuron 包时,北向应用管理界面中将有一个默认的data-stream-processing节点卡片,如下图所示。

data-stream-rules-adapter

这个数据流处理节点包含以下信息:

  • 应用程序名称 - data-stream-processing
  • 工作状态 - 运行中
  • 状态切换按键 - 打开
  • 连接状态 - 断开连接
  • 插件模块名称 - ekuiper

第二步,订阅南向标签组

点击 data-stream-processing 应用节点任意空白处,进入订阅 Group 的界面,如下图所示。

data-stream-rules-sub

订阅南向设备的数据组:

  • 点击右上角添加订阅
  • 点击下拉框,选择已构建的南向设备;
  • 点击下拉框,选择要订阅的 Group;
  • 点击提交按键完成订阅。