Stream Processing is a method of tracking and analyzing streams of information of an event, and eventually obtaining useful structured
conclusions out of that raw information.
SmartWorks IoTEdgeOps is a set of tools for building, maintaining and continuously improving code in resource constrained devices at the
edge of smart product ecosystems.
Stream Processing is a method of tracking and analyzing streams of information of an event, and eventually obtaining useful structured
conclusions out of that raw information.
In order to perform Stream Processing on MQTT data from
devices, you will need to create a Data source for those devices in
the Stream Processing tool. This will walk you through where to get
all the information you need and where to put it.
Open the Data Sources menu under Stream Processing.
To set this Data source to be only visible to you and to no
one else in your space, select the folder named for your user.
Select + New Data Source.
Enter a name for the new data source and click
Create.
Select the Connector dropdown.
Select MQTT in the Input section of the dropdown
list.
Note: You can also choose to send Data to a device from
the Stream Processing application, but this is done
through the Output version of an MQTT data source.
Update the broker URL to be
tcp://mqtt.swx.altairone.com:1883
Populate the Topic field with the MQTT topic of the AnythingDBThing from which you want to process data. This should be in
the format
set/<space>/collections/<collection>/things/<thing_id>/data
Populate the User Id. This can be found on the Security tab of the Details page
of the Thing you are trying to connect to.
Populate the Password. Likewise, this can be found on the Security tab of the
Details page of the Thing you are trying to connect to. You
can either set your own password or autogenerate one.
Select Generate Columns.
Note: Your device must be sending Data to generate
columns. If Stream Processing does not detect any
messages within the limit, it will timeout.