Contents¶

Contents
- EmbSubscriber

EmbSubscriber¶

EmbSubscriber subscribes message coming from the publisher. It subscribes to message bus topic to get the data.

Prerequisites¶

EmbSubscriber expects a set of config, interfaces & public private keys to be present in ETCD as a prerequisite.
To achieve this, ensure an entry for the EmbSubscriber with its relative path from the IEdgeInsights([WORK_DIR]/IEdgeInsights/) directory is set in the time-series.yml file present in build/usecases([WORK_DIR]/IEdgeInsights/build/usecases) directory.

For example:
```
AppName:
- ConfigMgrAgent
- Visualizer/multimodal-data-visualization/eii
- DataStore
- Kapacitor
- Telegraf
- tools/EmbSubscriber
```

After completing the previous prerequisites, execute the following command:

cd [WORKDIR]/IEdgeInsights/build
python3 builder.py -f usecases/time-series.yml

Run the EmbSubscriber¶

Refer to the ../README.md to provision, build and run the tool along with the EII Time Series recipe or stack.

Run the EmbSubscriber in IPC mode¶

To run EmbSubscriber in the IPC mode, modify the following interfaces section of the config.json([WORK_DIR]/IEdgeInsights/tools/EmbSubscriber/config.json) file:

{
  "config": {},
  "interfaces": {
    "Subscribers": [
      {
        "Name": "TestSub",
        "PublisherAppName": "Telegraf",
        "Type": "zmq_ipc",
        "EndPoint": {
                  "SocketDir": "/EII/sockets",
                  "SocketFile": "telegraf-out"
         },
        "Topics": [
          "*"
        ]
      }
    ]
  }
}