Neuron Source

Neuron source is provided to consume events from the local neuron instance. Notice that, the source is bound to the local neuron only which must be able to communicate through nanomsg ipc protocol without network. In the eKuiper side, all neuron source and sink instances share the same connection, thus the events consumed are also the same. The events are formatted in json by default. Notice that, the dial to neuron is async which will run in the background and always redial when the previous attempt fails, which means that the rule using neuron sink will not see an error even when neuron is down. While debugging, we need to check the rule status for the message in counts.

The event content and format are fixed as below: 

  1. {
  2.   "timestamp": 1646125996000,
  3.   "node_name": "node1", 
  4.   "group_name": "group1",
  5.   "values": {
  6.     "tag_name1": 11.22,
  7.     "tag_name2": "string"
  8.   },
  9.   "errors": {
  10.     "tag_name3": 122
  11.   }
  12. }

There is no configuration properties. An example of creating neuron source:

  1. CREATE STREAM table1 () WITH (FORMAT="json", TYPE="neuron");