Prerequisite Setup

    Users can choose to install Neuorn and eKuiper separately, and use docker-compose to install and configure them directly. The docker-compose.yml example is as follows, and the installed version can be selected according to requirements.

    3. services:
    5.   ekuiper-manager:
    6.     image: emqx/ekuiper-manager:1.5.0
    7.     container_name: ekuiper-manager
    8.     ports:
    9.       - "9082:9082"
    11.   ekuiper:
    12.     image: lfedge/ekuiper:1.5.1-slim
    13.     hostname: ekuiper
    14.     container_name: ekuiper
    15.     ports:
    16.       - "127.0.0.1:20498:20498"
    17.     environment:
    19.       KUIPER__BASIC__CONSOLELOG: "true"
    20.       KUIPER__BASIC__IGNORECASE: "false"
    21.     volumes:
    22.       - nng-ipc:/tmp
    24.   neuron:
    25.     image: emqx/neuron:2.3.0
    26.     hostname: neuron
    27.     container_name: neuron
    28.     ports:
    29.       - "7000:7000"
    30.     volumes:
    31.       - nng-ipc:/tmp
    33.   source:
    34.     image: alpine/httpie
    35.     container_name: httpie
    37.       - --check-status
    38.       - ekuiper:9081/streams
    39.       - sql=CREATE STREAM neuronStream() WITH (TYPE="neuron",FORMAT="json",SHARED="true");
    40.     depends_on:
    41.       - ekuiper
    42.       - neuron
    44. volumes:
    45.   nng-ipc:%

    After successful execution, Neuron and eKuiper have been started respectively.

    Login to kuiper-manager.

    • Address: http://$yourhost:9082
    • User name: admin
    • Password: public

    Add the service as shown.

    TIP

    The address in Endpoint should fill in the local address where eKuiper is launched.

    After adding the service, because docker-compose has created a data stream, there should be a neuronStream stream in the newly created service.

    For the specific operation of eKuiper, please refer to

    Dashboard

    When you install a .deb or .rpm Neuron package, there is a default data-stream-processing application node in the northbound application management screen, as shown below.

    data-stream-rules-adapter

    The data stream processing node contains the following information

    • Application Name - data-stream-processing
    • Status - Running
    • State Change Button - ON
    • Connection Status - Disconnected
    • Plugin Module Name - ekuiper

    Click on any blank space of the data-stream-processing application node to enter the Group list screen for subscribing to the group, as shown below.

    To subscribe the data Groups of southbound device,

    • Click on the Add subscription button in the top right corner.
    • Click on the drop down box to select the southbound device, in this case, we select the modbus-tcp-1 device built above.
    • Select the Group you want to subscribe to in the drop-down box, in this case, we select the group-1 created above.
    • Click on Submit button to complete the subscription.