This document is a continuation of the Basic Starter user guide. It aims to provide users with additional understanding on how to build and design your own customized Internet of Things pipeline in Reekoh.
In addition to the things we learned in the Basic Starter, the Advanced Starter will demonstrate users how to:
- Process and Enrich data from external Services.
- Transmits enriched data to the specified database.
We will use Service and Storage plugins such as Dark Sky, Google Geocoding, MongoDB, and MySQL to show how this works.
Let's get started!
1. Register a Device
Since this is an extension of the Basic Starter, we will be using the same registered device which is Device 1.
If you want to register another device, you may refer to the Basic Starter document for the procedure.
After configuring your device, we can now proceed on pinning additional plugins.
2. Pin Plugins
In this procedure, we will pin additional plugins to demonstrate how data is processed from your registered device.
First, we'll pin Dark Sky and Google Geocoding which are Service plugins. These plugins will get the current weather condition and outputs the readable address based on the latitude and longitude.
Navigate to Marketplace on the mega menu, and then select the Service tab. Hover over the Dark Sky plugin, and then click Pin on the pop-out window. You should be able to see a notification saying your plugin is pinned.
Do the same procedure for Google Geocoding.
After you've pinned your Service plugins, you need to pin MySQL and MongoDB. These are Storage plugins which enables you to store enriched device data.
Select the Storage tab, and then hover over the MySQL plugin. Click Pin on the pop-out window. You should be able to see a notification saying your plugin is pinned.
Do the same procedure for MongoDB.
After all plugins are pinned, we can now configure them in your Pipeline.
3. Build a Pipeline
For this demo, we will create a new pipeline to configure the additional plugins we'll be using.
To create a new pipeline, navigate to Pipeline Studio on the mega menu and then click Create a New Pipeline from the pop-out window.
In addition to the new plugins we've pinned, we will also be using the MQTT Gateway and HTTP Webhooks Connector plugins.
Let's start with Google Geocoding. Locate the Service category on the left pane, and then drag & drop the Google Geocoding plugin to your work space.
To configure, double-click the plugin and then complete the wizard that comes next. Click Save.
Do the same procedure for Dark Sky.
After you've configured your Service plugins, we'll proceed with the Storage plugins. Let's start with MySQL.
Locate the Storage category on the left pane, and then drag & drop the MySQL plugin to your work space.
To configure, double-click the plugin and then complete the wizard that comes next. Click Save.
Do the same procedure for MongoDB.
Once you've configured all plugins, connect them by dragging the output terminal of one plugin to the input terminal of another. You may refer to the image below for sample. Select Save & Deploy from the drop-down menu.
Complete the wizard that comes next, and then click Save. You should be able to see a message saying your pipeline has been deployed.
4. Connect and Send Data to the MQTT Gateway
After configuring your plugins, we can now proceed on connecting and sending data to the MQTT Gateway. To create a new device connection, open the MQTTLens chrome application and then click the Add icon.
Note: You can use any MQTT Client Simulator to connect to your gateway. Just locate and install them via Chrome Web Store.
Complete the following connection details:
- Connection name - Supply any name for your connection.
- Hostname - IP address generated upon deployment of your Reekoh pipeline.
- Port - Port number generated upon deployment of your Reekoh pipeline.
- Client ID - Device ID supplied or generated upon registration of your device.
Once all details have been completed, click Create Connection.
After connection has been established, you need to send a JSON Data to the MQTT Gateway. Under the Publish section, key-in or paste the JSON data on the Message field, and then supply a value for Topic. Click Publish to send data to the MQTT Gateway.
5. Verify Output
To check if JSON data has been received in Request Bin, type the webhook URL you've provided upon configuration of your HTTP Webhooks plugin and then add ?inspect in the address bar. For example, https://requestb.in/1hfag4u1?inspect. You should able to see the processed data under Raw Body. This includes the obtained weather condition and address based on the given latitude and longitude.
The image below also shows that data is successfully sent to the configured database.
Comments
0 comments
Please sign in to leave a comment.