Difference between revisions of "Datonis:Using the Datonis Java SDK"

From Datonis
Jump to: navigation, search
m
m
Line 15: Line 15:
 
=== Modifying the agent configuration file ===
 
=== Modifying the agent configuration file ===
 
The SampleAgent.java file contains a reference implementation of a Java based Agent that pushes data to Datonis. To run this agent, you will need to edit the aliot.properties file. Your aliot.properties file should look like this. This file follows the [http://www.json.org/ JSON] syntax. It is always a good idea to use a tool like [http://jsonlint.com/ JSONLint].  If the JSON syntax of this file is not valid, the Agent will throw parse errors.
 
The SampleAgent.java file contains a reference implementation of a Java based Agent that pushes data to Datonis. To run this agent, you will need to edit the aliot.properties file. Your aliot.properties file should look like this. This file follows the [http://www.json.org/ JSON] syntax. It is always a good idea to use a tool like [http://jsonlint.com/ JSONLint].  If the JSON syntax of this file is not valid, the Agent will throw parse errors.
{| class="wikitable"
 
!aliot.properties
 
|-
 
|{
 
 
"access_key": "<Your access key here>",
 
 
"secret_key": "<Your secret key here>",
 
 
"bulk_transmit": false,
 
 
"protocol": "mqtts"
 
 
}
 
|}
 
  
 
'''aliot.properties'''
 
'''aliot.properties'''
{| class="wikitable"
+
{
|<code>{</code>
+
    "access_key": "<Your access key here>",
 
+
    "secret_key": "<Your secret key here>",
    <code>"access_key": "<Your access key here>",</code>
+
    "bulk_transmit": false,   
 
+
    "protocol": "mqtts"
    <code>"secret_key": "<Your secret key here>",</code>
+
}
 
 
    <code>"bulk_transmit": false,</code>
 
 
 
    <code>"protocol": "mqtts"</code>
 
 
 
<code>}</code>
 
|}
 
 
* The access key and secret keys have been created by you earlier. Please refer to the documentation for this if you haven't. Copy the values for access_key and secret_key into the aliot.properties file. These keys are 40 character alphanumeric values. Please put the values in quotes. For example, "access_key": "ab12ab12ab12ab12ab12ab12ab12ab12"
 
* The access key and secret keys have been created by you earlier. Please refer to the documentation for this if you haven't. Copy the values for access_key and secret_key into the aliot.properties file. These keys are 40 character alphanumeric values. Please put the values in quotes. For example, "access_key": "ab12ab12ab12ab12ab12ab12ab12ab12"
 
* Additional configuration options in the file will be discussed in detail later. For now, you can keep the agent configuration file as specified above.
 
* Additional configuration options in the file will be discussed in detail later. For now, you can keep the agent configuration file as specified above.
  
 
=== Setting the Thing keys in the agent ===
 
=== Setting the Thing keys in the agent ===
Now that your aliot configuration is done, you will need to configure the Thing for which the agent is transmitting data. You have already created a  LivingRoom Thing in Datonis earlier.  Look for the code snippet below and replace the "<Your Thing Key>" with the actual Thing key.This ensures that the Agent pushes data for your newly created Thing.
+
Now that your aliot configuration is done, you will need to configure the Thing for which the agent is transmitting data. You have already created a  LivingRoom Thing in Datonis earlier.  Look for the code snippet below and replace the "<Your Thing Key>" with the actual Thing key. This ensures that the Agent pushes data for your newly created Thing.
{| class="wikitable"
+
thing = new Thing("<Your Thing Key>", "LivingRoom", "The living room temperature and humidity device.");
|<code>thing = new</code> <code>Thing("<Your Thing Key>", "LivingRoom", "The living room temperature and humidity device.");</code>
 
|}
 
  
 
=== Running the agent ===
 
=== Running the agent ===
 
You are now ready to run the agent for the first time. The agent needs to know where to find the aliot.properties and log4j.properties file. You will need to add JVM parameters for the same. In Eclipse, you will need to create a new Run Configuration for the SampleAgent. In the Arguments section, under VM Arguments, add the following settings
 
You are now ready to run the agent for the first time. The agent needs to know where to find the aliot.properties and log4j.properties file. You will need to add JVM parameters for the same. In Eclipse, you will need to create a new Run Configuration for the SampleAgent. In the Arguments section, under VM Arguments, add the following settings
{| class="wikitable"
+
-Daliot.properties=src/main/resources/aliot.properties
|<code>-Daliot.properties=src/main/resources/aliot.properties</code>
+
-Dlog4j.properties=src/main/resources/log4j.properties
 
 
<code>-Dlog4j.properties=src/main/resources/log4j.properties</code>
 
|}
 
 
If you have used [https://logging.apache.org/log4j/2.x/ Log4J] before, the log4j.properties file will be very familiar to you. The default setting is to log everything to the console and the aliot.log file. You can modify this based on your need.
 
If you have used [https://logging.apache.org/log4j/2.x/ Log4J] before, the log4j.properties file will be very familiar to you. The default setting is to log everything to the console and the aliot.log file. You can modify this based on your need.
  
 
Now run the agent. If everything has been set up properly, the agent will successfully connect and start transmitting data to Datonis. The you should see log messages indicating a successful agent transmit.
 
Now run the agent. If everything has been set up properly, the agent will successfully connect and start transmitting data to Datonis. The you should see log messages indicating a successful agent transmit.
{| class="wikitable"
+
2017-04-06 12:25:55,448 INFO  [main] SampleAgent - Starting the Sample Aliot Agent
|<code>2017-04-06</code> <code>12:25:55,448</code> <code>INFO  [main] SampleAgent - Starting the Sample Aliot Agent</code>
+
2017-04-06 12:25:55,457 INFO  [main] AliotGateway - Starting up the Aliot Gateway
 
+
2017-04-06 12:25:55,467 INFO  [main] AliotGateway - Agent will communicate using https
<code>2017-04-06</code> <code>12:25:55,457</code> <code>INFO  [main] AliotGateway - Starting up the Aliot Gateway</code>
+
2017-04-06 12:25:55,907 INFO  [Handshake-Consumer] GatewayMessageConsumer - Handshake-Consumer is starting up
 
+
2017-04-06 12:25:55,907 INFO  [Alert-Consumer] GatewayMessageConsumer - Alert-Consumer is starting up
<code>2017-04-06</code> <code>12:25:55,467</code> <code>INFO  [main] AliotGateway - Agent will communicate using https</code>
+
2017-04-06 12:25:55,907 INFO  [Data-Consumer] GatewayMessageConsumer - Data-Consumer is starting up
 
+
2017-04-06 12:25:55,908 INFO  [main] AliotGateway - Successfully started the Aliot Gateway
<code>2017-04-06</code> <code>12:25:55,907</code> <code>INFO  [Handshake-Consumer] GatewayMessageConsumer - Handshake-Consumer is starting up</code>
+
2017-04-06 12:25:55,908 INFO  [main] SampleAgent - Agent started Successfully, setting up bidirectional communication
 
+
2017-04-06 12:25:55,908 INFO  [Gateway-Monitor] GatewayMonitor - Gateway monitor starting up
<code>2017-04-06</code> <code>12:25:55,907</code> <code>INFO  [Alert-Consumer] GatewayMessageConsumer - Alert-Consumer is starting up</code>
+
2017-04-06 12:25:55,909 INFO  [Gateway-Monitor] GatewayMonitor - Sent heart beats for the Things
 
+
2017-04-06 12:25:55,909 INFO  [main] SampleAgent - Bidirectional communication is setup with Datonis
<code>2017-04-06</code> <code>12:25:55,907</code> <code>INFO  [Data-Consumer] GatewayMessageConsumer - Data-Consumer is starting up</code>
+
2017-04-06 12:25:55,910 INFO  [main] SampleAgent - Transmitting Demo Data
 
+
2017-04-06 12:25:57,975 INFO  [Handshake-Consumer-pool-thread-1] GatewayMessageConsumer - Transmitted Message in 2061 ms : {"timestamp":1491461755909,"thing_key":"your_thing_key"}
<code>2017-04-06</code> <code>12:25:55,908</code> <code>INFO  [main] AliotGateway - Successfully started the Aliot Gateway</code>
+
2017-04-06 12:25:57,975 INFO  [Data-Consumer-pool-thread-1] GatewayMessageConsumer - Transmitted Message in 2061 ms : {"timestamp":1491461755910,"data":{"humidity":66,"temperature":20},"thing_key":"your_thing_key"}
 
+
2017-04-06 12:26:06,774 INFO  [Data-Consumer-pool-thread-2] GatewayMessageConsumer - Transmitted Message in 859 ms : {"timestamp":1491461765914,"data":{"humidity":85,"temperature":4},"thing_key":"your_thing_key"}
<code>2017-04-06</code> <code>12:25:55,908</code> <code>INFO  [main] SampleAgent - Agent started Successfully, setting up bidirectional communication</code>
 
 
 
<code>2017-04-06</code> <code>12:25:55,908</code> <code>INFO  [Gateway-Monitor] GatewayMonitor - Gateway monitor starting up</code>
 
 
 
<code>2017-04-06</code> <code>12:25:55,909</code> <code>INFO  [Gateway-Monitor] GatewayMonitor - Sent heart beats for</code> <code>the Things</code>
 
 
 
<code>2017-04-06</code> <code>12:25:55,909</code> <code>INFO  [main] SampleAgent - Bidirectional communication is setup with Datonis</code>
 
 
 
<code>2017-04-06</code> <code>12:25:55,910</code> <code>INFO  [main] SampleAgent - Transmitting Demo Data</code>
 
 
 
<code>2017-04-06</code> <code>12:25:57,975</code> <code>INFO  [Handshake-Consumer-pool-thread-1] GatewayMessageConsumer - Transmitted Message in 2061</code> <code>ms : {"timestamp":1491461755909,"thing_key":"your_thing_key"}</code>
 
 
 
<code>2017-04-06</code> <code>12:25:57,975</code> <code>INFO  [Data-Consumer-pool-thread-1] GatewayMessageConsumer - Transmitted Message in 2061</code> <code>ms : {"timestamp":1491461755910,"data":{"humidity":66,"temperature":20},"thing_key":"your_thing_key"}</code>
 
 
 
<code>2017-04-06</code> <code>12:26:06,774</code> <code>INFO  [Data-Consumer-pool-thread-2] GatewayMessageConsumer - Transmitted Message in 859</code> <code>ms : {"timestamp":1491461765914,"data":{"humidity":85,"temperature":4},"thing_key":"your_thing_key"}</code>
 
|}
 
 
Please ensure that you have a '''working internet connection''' so that the agent can transmit. If you are sitting behind a proxy, the section below will show you how to configure the proxy settings.
 
Please ensure that you have a '''working internet connection''' so that the agent can transmit. If you are sitting behind a proxy, the section below will show you how to configure the proxy settings.
  
 
If there are any issues, the agent will print an appropriate error on the console. For instance, here's an error that's printed if the Thing key is invalid.
 
If there are any issues, the agent will print an appropriate error on the console. For instance, here's an error that's printed if the Thing key is invalid.
{| class="wikitable"
+
2017-04-06 11:53:57,755 ERROR [Data-Consumer-pool-thread-1] RESTCommunicator - Error 300025 : Invalid sensor key or thing key.
|<code>2017-04-06</code> <code>11:53:57,755</code> <code>ERROR [Data-Consumer-pool-thread-1] RESTCommunicator - Error 300025</code> <code>: Invalid sensor key or thing key.</code>
 
|}
 
 
You can now verify that the Datonis platform has indeed recognised this Thing and is accepting data by clicking on Home and looking at the System Summary dashboard.
 
You can now verify that the Datonis platform has indeed recognised this Thing and is accepting data by clicking on Home and looking at the System Summary dashboard.
  
Line 142: Line 97:
 
| colspan="1" |Yes
 
| colspan="1" |Yes
 
|-
 
|-
|
+
|bulk_transmit_interval
bulk_transmit_interval
 
 
| colspan="1" |The interval at which the metrics should be transmitted. Unit is in milliseconds. For instance, setting this value to 60000 means that the agent will transmit the collected metrics every 60 seconds.
 
| colspan="1" |The interval at which the metrics should be transmitted. Unit is in milliseconds. For instance, setting this value to 60000 means that the agent will transmit the collected metrics every 60 seconds.
 
| colspan="1" |Integer
 
| colspan="1" |Integer
Line 149: Line 103:
 
| colspan="1" |No
 
| colspan="1" |No
 
|-
 
|-
|
+
|bulk_max_elements
bulk_max_elements
 
 
|How many events to batch before finally sending the batch. For instance, setting the value to 25 means that the agent will send metrics in batches of 25.
 
|How many events to batch before finally sending the batch. For instance, setting the value to 25 means that the agent will send metrics in batches of 25.
 
|Integer
 
|Integer
Line 156: Line 109:
 
|No
 
|No
 
|-
 
|-
|
+
|proxy_host
proxy_host
 
 
|If your internet connection is through a proxy, you will need to set the proxy details by providing values for the proxy host.
 
|If your internet connection is through a proxy, you will need to set the proxy details by providing values for the proxy host.
 
|String
 
|String
Line 163: Line 115:
 
|No
 
|No
 
|-
 
|-
|
+
|proxy_port
proxy_port
 
 
|The proxy server port
 
|The proxy server port
 
|Integer
 
|Integer
Line 170: Line 121:
 
|No
 
|No
 
|-
 
|-
|
+
|proxy_username
proxy_username
 
 
|The proxy server username
 
|The proxy server username
 
|String
 
|String
Line 177: Line 127:
 
|No
 
|No
 
|-
 
|-
|
+
|proxy_password
proxy_password
 
 
|The proxy server password
 
|The proxy server password
 
|String
 
|String
Line 184: Line 133:
 
|No
 
|No
 
|-
 
|-
|
+
|request_timeout
request_timeout
 
 
| colspan="1" |Timeout while connecting/receiving response from the platform. Usually defaults work very well but you can increase the value if you have a slow connection and need a larger request timeout. The value is in milliseconds.
 
| colspan="1" |Timeout while connecting/receiving response from the platform. Usually defaults work very well but you can increase the value if you have a slow connection and need a larger request timeout. The value is in milliseconds.
 
| colspan="1" |Integer
 
| colspan="1" |Integer
Line 191: Line 139:
 
| colspan="1" |No
 
| colspan="1" |No
 
|-
 
|-
|
+
|thread_pool_size
thread_pool_size
 
 
| colspan="1" |The agent uses a pool of transmitting threads. This is useful to achieve parallelism when you are transmitting a lot of data. Usually the default works well for most scenarios but you can increase the value if you are transmitting a lot of data.
 
| colspan="1" |The agent uses a pool of transmitting threads. This is useful to achieve parallelism when you are transmitting a lot of data. Usually the default works well for most scenarios but you can increase the value if you are transmitting a lot of data.
 
| colspan="1" |Integer
 
| colspan="1" |Integer
Line 198: Line 145:
 
| colspan="1" |No
 
| colspan="1" |No
 
|-
 
|-
| colspan="1" |
+
| colspan="1" |heartbeat_interval
heartbeat_interval
 
 
| colspan="1" |The agent transmits heartbeats at a periodic interval to indicate that the agent is alive. This way the Datonis platform knows that the agent is connected and functioning properly. The default value is a heartbeat every 60 seconds. You can override it if you wish. The value in in milliseconds.
 
| colspan="1" |The agent transmits heartbeats at a periodic interval to indicate that the agent is alive. This way the Datonis platform knows that the agent is connected and functioning properly. The default value is a heartbeat every 60 seconds. You can override it if you wish. The value in in milliseconds.
 
| colspan="1" |Integer
 
| colspan="1" |Integer
Line 209: Line 155:
 
The SampleAgent code is well documented so going through that code should give you a fair idea of how to transmit data to Datonis. You should start by looking at the main function. It shows you how to initialise the agent, transmit a few data points and alerts, transmitting waypoints and handling control instructions from the Datonis platform
 
The SampleAgent code is well documented so going through that code should give you a fair idea of how to transmit data to Datonis. You should start by looking at the main function. It shows you how to initialise the agent, transmit a few data points and alerts, transmitting waypoints and handling control instructions from the Datonis platform
  
'''Main''' Collapse source
+
// First make sure you create an aliot.properties file using your access and secret keys.
{| class="wikitable"
+
// A sample file should be available with this package
|<code>// First make sure you create an aliot.properties file using your access and secret keys.</code>
+
// The keys are available in the Datonis platform portal
 
+
logger.info("Starting the Sample Aliot Agent");
<code>// A sample file should be available with this package</code>
+
 
+
// Create and Initialize the agent
<code>// The keys are available in the Datonis platform portal</code>
+
SampleAgent agent = new SampleAgent();
 
+
 <code>logger.info("Starting the Sample Aliot Agent");</code>
+
// Start the Gateway
 
+
if (!agent.startGateway())
<code>// Create and Initialize the agent</code>
+
{
 
+
    logger.info("Could not start the agent. Exiting");
<code>SampleAgent agent = new</code> <code>SampleAgent();</code>
+
    return;
 
+
}
<code>// Start the Gateway</code>
+
logger.info("Agent started Successfully, setting up bidirectional communication");
 
+
<code>if</code> <code>(!agent.startGateway())</code>
+
// Setup bidirectional communication - Needs to use MQTTS/MQTT mode for communication.
 
+
// Ensure that the 'protocol' property is set to 'mqtts' in the aliot.properties file
<code>{</code>
+
agent.setupBiDirectionalCommunication();
 
+
    <code>logger.info("Could not start the agent. Exiting");</code>
+
// Send a few sample simulated data events
 
+
logger.info("Transmitting Data");
    <code>return;</code>
+
agent.transmitData();
 
+
<code>}</code>
+
// Transmit a set of sample alerts.
 
+
logger.info("Transmitting Alerts");
<code>logger.info("Agent started Successfully, setting up bidirectional communication");</code>
+
agent.transmitAlerts();
 
+
<code>// Setup bidirectional communication - Needs to use MQTTS/MQTT mode for communication.</code>
+
// Transmit a waypoint
 
+
logger.info("Transmitting a waypoint");
<code>// Ensure that the 'protocol' property is set to 'mqtts' in the aliot.properties file</code>
+
agent.transmitWaypoint();
 
+
logger.info("Exiting");
<code>agent.setupBiDirectionalCommunication();</code>
+
agent.stopGateway();
 
 
<code>// Send a few sample simulated data events</code>
 
 
 
<code>logger.info("Transmitting Data");</code>
 
 
 
<code>agent.transmitData();</code>
 
 
 
<code>// Transmit a set of sample alerts.</code>
 
 
 
<code>logger.info("Transmitting Alerts");</code>
 
 
 
<code>agent.transmitAlerts();</code>
 
 
 
<code>// Transmit a waypoint</code>
 
 
 
<code>logger.info("Transmitting a waypoint");</code>
 
 
 
<code>agent.transmitWaypoint();</code>
 
 
 
<code>logger.info("Exiting");</code>
 
 
 
<code>agent.stopGateway();</code>
 
|}
 

Revision as of 09:16, 1 July 2017

Installing the SDK

To get started with the Java SDK, you will first need to install the Apache Maven build tool. Please follow the installation instructions for your Operating System.

All our code samples are available in our GitHub repository. If you are familiar with Git, you can pull the repository to begin. If not, you can download the entire repository of code samples as a zip file by clicking on the clone or download link.

Extract the zip file in a folder. You now need to go into the java folders and execute the following Maven commands to install the Java SDK and all its dependent libraries.

mvn install:install-file -Dfile=lib/aliot-sdk-4.0.0.jar -DgroupId=io.datonis.sdk -DartifactId=aliot-sdk -Dversion=4.0.0 -Dpackaging=jar
mvn clean install

We recommend using the Eclipse IDE to program the SDK. The following command generates the necessary project and dependency files required for Eclipse.

mvn eclipse:eclipse

This command generates the necessary .project and .classpath files that Eclipse needs. You can now import this project into Eclipse by clicking on File → Import and selecting General → Existing Projects into Workspace. You will see a new project called Aliot SDK example added to your workspace.

Running the Agent for the first time

Modifying the agent configuration file

The SampleAgent.java file contains a reference implementation of a Java based Agent that pushes data to Datonis. To run this agent, you will need to edit the aliot.properties file. Your aliot.properties file should look like this. This file follows the JSON syntax. It is always a good idea to use a tool like JSONLint.  If the JSON syntax of this file is not valid, the Agent will throw parse errors.

aliot.properties

{
    "access_key": "<Your access key here>",
    "secret_key": "<Your secret key here>",
    "bulk_transmit": false,   
    "protocol": "mqtts"
}
  • The access key and secret keys have been created by you earlier. Please refer to the documentation for this if you haven't. Copy the values for access_key and secret_key into the aliot.properties file. These keys are 40 character alphanumeric values. Please put the values in quotes. For example, "access_key": "ab12ab12ab12ab12ab12ab12ab12ab12"
  • Additional configuration options in the file will be discussed in detail later. For now, you can keep the agent configuration file as specified above.

Setting the Thing keys in the agent

Now that your aliot configuration is done, you will need to configure the Thing for which the agent is transmitting data. You have already created a  LivingRoom Thing in Datonis earlier.  Look for the code snippet below and replace the "<Your Thing Key>" with the actual Thing key. This ensures that the Agent pushes data for your newly created Thing.

thing = new Thing("<Your Thing Key>", "LivingRoom", "The living room temperature and humidity device.");

Running the agent

You are now ready to run the agent for the first time. The agent needs to know where to find the aliot.properties and log4j.properties file. You will need to add JVM parameters for the same. In Eclipse, you will need to create a new Run Configuration for the SampleAgent. In the Arguments section, under VM Arguments, add the following settings

-Daliot.properties=src/main/resources/aliot.properties
-Dlog4j.properties=src/main/resources/log4j.properties

If you have used Log4J before, the log4j.properties file will be very familiar to you. The default setting is to log everything to the console and the aliot.log file. You can modify this based on your need.

Now run the agent. If everything has been set up properly, the agent will successfully connect and start transmitting data to Datonis. The you should see log messages indicating a successful agent transmit.

2017-04-06 12:25:55,448 INFO  [main] SampleAgent - Starting the Sample Aliot Agent
2017-04-06 12:25:55,457 INFO  [main] AliotGateway - Starting up the Aliot Gateway
2017-04-06 12:25:55,467 INFO  [main] AliotGateway - Agent will communicate using https
2017-04-06 12:25:55,907 INFO  [Handshake-Consumer] GatewayMessageConsumer - Handshake-Consumer is starting up
2017-04-06 12:25:55,907 INFO  [Alert-Consumer] GatewayMessageConsumer - Alert-Consumer is starting up
2017-04-06 12:25:55,907 INFO  [Data-Consumer] GatewayMessageConsumer - Data-Consumer is starting up
2017-04-06 12:25:55,908 INFO  [main] AliotGateway - Successfully started the Aliot Gateway
2017-04-06 12:25:55,908 INFO  [main] SampleAgent - Agent started Successfully, setting up bidirectional communication
2017-04-06 12:25:55,908 INFO  [Gateway-Monitor] GatewayMonitor - Gateway monitor starting up
2017-04-06 12:25:55,909 INFO  [Gateway-Monitor] GatewayMonitor - Sent heart beats for the Things
2017-04-06 12:25:55,909 INFO  [main] SampleAgent - Bidirectional communication is setup with Datonis
2017-04-06 12:25:55,910 INFO  [main] SampleAgent - Transmitting Demo Data
2017-04-06 12:25:57,975 INFO  [Handshake-Consumer-pool-thread-1] GatewayMessageConsumer - Transmitted Message in 2061 ms : {"timestamp":1491461755909,"thing_key":"your_thing_key"}
2017-04-06 12:25:57,975 INFO  [Data-Consumer-pool-thread-1] GatewayMessageConsumer - Transmitted Message in 2061 ms : {"timestamp":1491461755910,"data":{"humidity":66,"temperature":20},"thing_key":"your_thing_key"}
2017-04-06 12:26:06,774 INFO  [Data-Consumer-pool-thread-2] GatewayMessageConsumer - Transmitted Message in 859 ms : {"timestamp":1491461765914,"data":{"humidity":85,"temperature":4},"thing_key":"your_thing_key"}

Please ensure that you have a working internet connection so that the agent can transmit. If you are sitting behind a proxy, the section below will show you how to configure the proxy settings.

If there are any issues, the agent will print an appropriate error on the console. For instance, here's an error that's printed if the Thing key is invalid.

2017-04-06 11:53:57,755 ERROR [Data-Consumer-pool-thread-1] RESTCommunicator - Error 300025 : Invalid sensor key or thing key.

You can now verify that the Datonis platform has indeed recognised this Thing and is accepting data by clicking on Home and looking at the System Summary dashboard.

Here the Dashboard is indicating that your Thing LivingRoom has connected and is transmitting data. Please note that you are transmitting two metrics, temperature and humidity. Therefore the counts for the metrics in the Live Data Feed will reflect the actual counts of metrics received.

Additional Agent Configurations

You have already configured the aliot.configurations file. Here are some additional configuration settings that you can use.

options description Data type Default value Mandatory
access_key Access key associated with a key pair. String None Yes
secret_key Secret key associated with the key pair. String None Yes
protocol Sets the protocol used to transmit data. This should be set to MQTTS. MQTT is a highly efficient bi-directional protocol suitable for IoT. MQTTS is MQTT over SSL. MQTTS is also bi-directional. The agent will use the 8883 port to communicate so please ensure that it is open.

You can also use HTTPS if you cannot use MQTTS.

Valid values are HTTP/HTTPS/MQTT/MQTTS

String HTTPS Yes
bulk_transmit If set to true, the agent will keep collecting metrics and transmits them in bulk at the interval specified by the bulk_transmit_interval parameter. Metrics are batched up in batch sizes specified by the bulk_max_elements parameter. This is extremely useful in low bandwidth scenarios and is also very efficient if you have a lot of metrics to transmit. The agent will transmit metrics immediately if this is set to false. Boolean true Yes
bulk_transmit_interval The interval at which the metrics should be transmitted. Unit is in milliseconds. For instance, setting this value to 60000 means that the agent will transmit the collected metrics every 60 seconds. Integer 120000 No
bulk_max_elements How many events to batch before finally sending the batch. For instance, setting the value to 25 means that the agent will send metrics in batches of 25. Integer 25 No
proxy_host If your internet connection is through a proxy, you will need to set the proxy details by providing values for the proxy host. String No No
proxy_port The proxy server port Integer No No
proxy_username The proxy server username String No No
proxy_password The proxy server password String No No
request_timeout Timeout while connecting/receiving response from the platform. Usually defaults work very well but you can increase the value if you have a slow connection and need a larger request timeout. The value is in milliseconds. Integer 10000 No
thread_pool_size The agent uses a pool of transmitting threads. This is useful to achieve parallelism when you are transmitting a lot of data. Usually the default works well for most scenarios but you can increase the value if you are transmitting a lot of data. Integer 5 No
heartbeat_interval The agent transmits heartbeats at a periodic interval to indicate that the agent is alive. This way the Datonis platform knows that the agent is connected and functioning properly. The default value is a heartbeat every 60 seconds. You can override it if you wish. The value in in milliseconds. Integer 60000 No

Agent Code Walkthrough

The SampleAgent code is well documented so going through that code should give you a fair idea of how to transmit data to Datonis. You should start by looking at the main function. It shows you how to initialise the agent, transmit a few data points and alerts, transmitting waypoints and handling control instructions from the Datonis platform

// First make sure you create an aliot.properties file using your access and secret keys.
// A sample file should be available with this package
// The keys are available in the Datonis platform portal
logger.info("Starting the Sample Aliot Agent");

// Create and Initialize the agent
SampleAgent agent = new SampleAgent();

// Start the Gateway
if (!agent.startGateway())
{
    logger.info("Could not start the agent. Exiting");
    return;
}
logger.info("Agent started Successfully, setting up bidirectional communication");

// Setup bidirectional communication - Needs to use MQTTS/MQTT mode for communication.
// Ensure that the 'protocol' property is set to 'mqtts' in the aliot.properties file
agent.setupBiDirectionalCommunication();

// Send a few sample simulated data events
logger.info("Transmitting Data");
agent.transmitData();

// Transmit a set of sample alerts.
logger.info("Transmitting Alerts");
agent.transmitAlerts();

// Transmit a waypoint
logger.info("Transmitting a waypoint");
agent.transmitWaypoint();
logger.info("Exiting");
agent.stopGateway();