eKuiper

eKuiper插件用于将 NeuronEX 数采模块的数据发送到数据处理模块。

在 NeuronEX 的北向应用 页面已经默认配置的 eKuiper 类型的节点 DataProcessing，并做好了参数配置。用户只需要将南向驱动数据添加订阅到DataProcessing节点即可。

添加订阅

点击操作栏中的添加订阅，并进行如下设置：

• 南向设备：选择要订阅的南向设备，例如，m1；
• 组：选择南向设备下的某个组，例如，group1。

至此，我们将能通过 DataProcessing 节点 将南向驱动m1的group1组中的数据，发送到数据处理模块的 neuronStream流里进行下一步处理。

有关在数据处理模块中的操作，见neuronStream。

提示

当数据处理模块中的neuronStream流，在规则中使用并有数据流入后，DataProcessing节点的连接状态才会变为已连接。

数据格式

通过 Dataprocessing 节点发送到neuronStream的消息为固定的 json 格式，如下所示：

{
  "timestamp": 1646125996000,
  "node_name": "node1", 
  "group_name": "group1",
  "values": {
    "tag_name1": 11.22,
    "tag_name2": "string"
  },
  "errors": {},
  "metas":{}
}

反向控制

数据处理模块通过Neuron Sink可以通过 DataProcessing 节点，向南向驱动下发写命令来控制设备。关于这部分的详细操作，见Neuron Sink。