You are using SAP Data Hub 2.4, developer edition, and have container datahub
running. You can check it by executing
docker ps -f name=datahub
In SAP Data Hub Modeller go to Graphs tab. Create a new graph.
Save the graph with parameters.
Field | Value |
---|---|
Name | codejam.warmup.mqtttcp.tessel |
Description | MQTT-TCP-based IoT data wiretap |
Category | CodeJam (type it if not yet existing) |
Click on Show Configuration of the graph. Change the icon to a at
. Save the graph.
You should see an icon of the graph changed in CodeJam
category.
Add an “MQTT Consumer” operator.
Define parameters of the operator as following.
Field | Value |
---|---|
mqttBroker | tcp://mqtt.eclipse.org:1883 tcp://test.mosquitto.org:1883 |
topic | sapcodejam/+/warmup/# |
mqttClientID | ccjdhw<location><your-user-ID> |
For MQTT protocol to work it is extremely important that each client has a unique ID!
Add an “Wiretap” operator.
Connect outmessage
out port from "MQTT Consumer" operator to in
in port of "Wiretap".
Now you have a graph that can receive data from the MQTT server to display it in wiretap.
Save and run the graph.
Open the wiretap's UI of the running graph and check if IoT data is coming!
This is the end of the scenario, where you built a graph to learn about:
- Creating and running a data pipeline,
- Wiretap operator.