Difference between revisions of "Connectivity/Agent Communication Protocol in MQTT"

From ESS-WIKI
Jump to: navigation, search
(Disconnect)
(EventNotify)
 
(32 intermediate revisions by 3 users not shown)
Line 1: Line 1:
=Overview=
+
= Overview =
 +
 
 
:Introduction for "WISEAgent communication protocol". WISEAgent communication protocol is base on standard MQTT protocol. We also define Advantech IoT Topic and message in JSON format. Follow standard to design our [[http://ess-wiki.advantech.com.tw/view/IoTGateway/SDK/WirelessSensorNetworkSDK|Advantech Sensor Format in JSON ]]
 
:Introduction for "WISEAgent communication protocol". WISEAgent communication protocol is base on standard MQTT protocol. We also define Advantech IoT Topic and message in JSON format. Follow standard to design our [[http://ess-wiki.advantech.com.tw/view/IoTGateway/SDK/WirelessSensorNetworkSDK|Advantech Sensor Format in JSON ]]
  
=Protocol=
+
= Protocol =
==Connect==
+
 
*Description: Agent Client sends the "Connect Info" to Server for on-line notification.
+
== Connect ==
 +
 
 +
*Description: Agent Client sends the "Connect Info" to RMM Server for on-line notification.
 
*Type: Info
 
*Type: Info
 
*Direction: Agent -> Server
 
*Direction: Agent -> Server
*Topic: /cagent/admin/<devID>/agentinfoack
+
*Topic: /cagent/admin/&lt;devID&gt;/agentinfoack
 
*QoS: 2
 
*QoS: 2
 
*Retained: 0
 
*Retained: 0
 
*Payload:
 
*Payload:
 +
 
  {
 
  {
 
   "susiCommData": {
 
   "susiCommData": {
Line 30: Line 34:
 
  }
 
  }
  
==Disconnect==
+
== Disconnect ==
 +
 
 
*Description: Agent Client sends the "Disconnect Info" to Server for off-line notification.
 
*Description: Agent Client sends the "Disconnect Info" to Server for off-line notification.
 
*Type: Info
 
*Type: Info
 
*Direction: Agent -> Server
 
*Direction: Agent -> Server
*Topic: /cagent/admin/<devID>/agentinfoack
+
*Topic: /cagent/admin/&lt;devID&gt;/agentinfoack
 
*QoS: 2
 
*QoS: 2
 
*Retained: 0
 
*Retained: 0
 
*Payload:
 
*Payload:
 +
 
  {
 
  {
 
   "susiCommData": {
 
   "susiCommData": {
Line 57: Line 63:
 
  }
 
  }
  
==Send or Auto Update Device's Capability==
+
== Will Message ==
Description: Agent will send it's capability to Server for description all resource.
+
 
Type: Auto update
+
*Description: While Client lost connection or keep-alive timeout, the will message will send to the client that subscribe the topic
Direction: Agent-> Server
+
*Type: Info
Topic: /cagent/admin/<devID>/agentactionreq
+
*Direction: Agent -> Broker
QoS: 0
+
*Topic: /cagent/admin/devId/willmessage
Retained: 0
+
*QoS: 0
Payload:
+
*Retained: 0
 +
*Payload:
 +
 
 +
{
 +
&nbsp;&nbsp; &nbsp;"susiCommData": {
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"devID": "000014DAE996BE04",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"hostname": "PC001104",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"sn": "14DAE996BE04",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"mac": "14DAE996BE04",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"version": "1.0.0.0",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"type": "IPC",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"product": "",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"manufacture": "",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"account": "anonymous",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"password": "",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"status": 0,
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"commCmd": 1,
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"requestID": 21,
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"agentID": "000014DAE996BE04",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"handlerName": "general",
 +
&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;"sendTS": 1423536737
 +
&nbsp;&nbsp; &nbsp;}
 +
}
 +
 
 +
== OS Info ==
 +
 
 +
*Description: Agent Client sends the OS Info" to RMM Server for device OS information.
 +
*Type: Info
 +
*Direction: Agent -> Server
 +
*Topic: /cagent/admin/&lt;devID&gt;/agentactionreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
<pre>{
 +
  "susiCommData":{
 +
    "osInfo":
 +
      {
 +
        "cagentVersion":"3.1.23",
 +
        "cagentType":"IoTGW",
 +
        "osVersion":"SnailOS",
 +
        "biosVersion":"",
 +
        "platformName":"",
 +
        "processorName":"SnailGW",
 +
        "osArch":"SnailX86",
 +
        "totalPhysMemKB":123,
 +
        "macs":"000E40ABCDEF",
 +
        "IP":"192.168.0.100"
 +
    },
 +
    "commCmd":116,
 +
    "requestID":109,
 +
    "agentID":"0000000E40ABCDEF",
 +
    "handlerName":"general",
 +
    "sendTS":1466730390
 +
  }
 +
}</pre>
 +
 
 +
 
 +
 
 +
== Info or Update Device's Capability ==
 +
 
 +
*Description: Agent will send it's capability to Server for description all resource.
 +
*Type: Auto update
 +
*Direction: Agent-> Server
 +
*Topic: /cagent/admin/&lt;devID&gt;/agentactionreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:&nbsp;
 +
 
 +
Example: SenHub's Capability
 +
 
 
  {
 
  {
 
   "susiCommData":{
 
   "susiCommData":{
Line 97: Line 172:
 
  }
 
  }
  
==Auto Update Sensor Data Value==
+
== Eable Auto&nbsp;Update&nbsp; ==
Description: Agent will update latest value to server.
+
 
Type: Auto update
+
*Description: Server can send start auto report command to Agent
Direction: Agent-> Server
+
*Type: Auto report
Topic: /cagent/admin/<devID>/deviceinfo
+
*Direction: Server -> Agent
QoS: 0
+
*Topic: /cagent/admin/&lt;device&gt;/agentcallbackreq
Retained: 0
+
*Broadcast Topic: /cagent/admin/broadcast/agentctrl
Payload:
+
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 +
{
 +
&nbsp; &nbsp;"susiCommData": {
 +
&nbsp; &nbsp; &nbsp; "commCmd": 2053,
 +
&nbsp; &nbsp; &nbsp; "requestItems": {"All":{}},
 +
&nbsp; &nbsp; &nbsp; "autoUploadIntervalSec": 10,
 +
&nbsp; &nbsp; &nbsp; "handlerName": "general"
 +
&nbsp; &nbsp;}
 +
}
 +
 
 +
*Description: Agent reply&nbsp;
 +
*Type: Reply of auto report command
 +
*Direction: Server -> Agent
 +
*Topic: /cagent/admin/&lt;device&gt;/agentactionreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
<pre>{
 +
  "susiCommData": {
 +
    "result": "SUCCESS",
 +
    "dataFlow": "general/NetMonitor",
 +
    "seq": "70_1611629702692",
 +
    "srcTs": 1611629702692,
 +
    "commCmd": 2054,
 +
    "agentID": "NetMonitor",
 +
    "handlerName": "general",
 +
    "sendTS": : 1611629702692
 +
  }
 +
}</pre>
 +
 
 +
== Stope Auto&nbsp;Update&nbsp; ==
 +
 
 +
*Description: Server can send stop&nbsp;auto report command to Agent
 +
*Type: Auto update
 +
*Direction: Server -> Agent
 +
*Topic: /cagent/admin/&lt;device&gt;/agentcallbackreq
 +
*Broadcast Topic: /cagent/admin/broadcast/agentctrl
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 +
{
 +
&nbsp; "susiCommData": {
 +
&nbsp; &nbsp; "requestID": 1001,
 +
&nbsp; &nbsp; "catalogID": 4,
 +
&nbsp; &nbsp; "commCmd": 2056,
 +
&nbsp; &nbsp; "handlerName": "general",
 +
&nbsp; &nbsp; "requestItems": {
 +
&nbsp; &nbsp; &nbsp; "All": {}
 +
&nbsp; &nbsp; }
 +
&nbsp; }
 +
}
 +
 
 +
== Auto Update Sensor Data Value ==
 +
 
 +
*Description: Agent will update latest value to server.
 +
*Type: Auto update
 +
*Direction: Agent-> Server
 +
*Topic: /cagent/admin/&lt;devID&gt;/deviceinfo
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 
  {   
 
  {   
 
   "susiCommData":{   
 
   "susiCommData":{   
Line 110: Line 250:
 
         "SenHub":{   
 
         "SenHub":{   
 
             "SenData":{   
 
             "SenData":{   
               "e":[
+
               "e":[{"n":"Temperature","v":1},
                  {
+
                    {"n":"Humidity","v":57},
                    "n":"Temperature",
+
                    {"n":"GPIO1","bv":0},
                    "v":1
+
                    {"n":"GPIO2","bv":0}],
                  },
 
                  {
 
                    "n":"Humidity",
 
                    "v":57
 
                  },
 
                  {
 
                    "n":"GPIO1",
 
                    "bv":0
 
                  },
 
                  {
 
                    "n":"GPIO2",
 
                    "bv":0
 
                  }
 
              ],
 
 
               "bn":"SenData"
 
               "bn":"SenData"
 
             },
 
             },
Line 140: Line 266:
 
   }
 
   }
 
  }
 
  }
==Get Sensor Data==
+
 
Description: Server can send mqtt message to get sensor data value.
+
== Start Monitor Request ==
Type: Request
+
 
Direction: Server -> Agent
+
*Description: Server send the&nbsp;start monitor requestto Agent to trigger a plugin to report data with&nbsp;reply topic.
Topic: /cagent/admin/<devID>/agentcallbackreq
+
*Type: Auto update
QoS: 0
+
*Direction: Server -> Agent
Retained: 0
+
*Topic: /cagent/admin/&lt;devID&gt;/agentcallbackreq
Payload:
+
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 +
{
 +
&nbsp; "susiCommData": {
 +
&nbsp; &nbsp; "commCmd": 533,
 +
&nbsp; &nbsp; "catalogID": 4,
 +
&nbsp; &nbsp; "requestID": 10,
 +
&nbsp; &nbsp; "autoUploadIntervalMs": 10000,
 +
&nbsp; &nbsp; "autoUploadTimeoutMs": 30000
 +
&nbsp; }
 +
}
 +
 
 +
*Description: Agent will reply sensor data every autoUploadIntervalMs&nbsp;( millisecond ) duration autoUploadTimeoutMs.
 +
*Type: Reply
 +
*Direction: Agent -> Server
 +
*Topic: /cagent/admin/&lt;devID&gt;/agentactionreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload: Refer to Auto Update Sensor Data Value
 +
<pre>{
 +
&nbsp; "susiCommData": {
 +
&nbsp; &nbsp; "OPCUAClient": {
 +
&nbsp; &nbsp; &nbsp; "info": {
 +
&nbsp; &nbsp; &nbsp; &nbsp; "bn": "info",
 +
&nbsp; &nbsp; &nbsp; &nbsp; "e": [
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; "n": "type",
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; "sv": "Protocol-Converter",
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; "asm": "r"
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; },
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; "n": "name",
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; "sv": "OPCUAClient",
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; "asm": "r"
 +
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }
 +
&nbsp; &nbsp; &nbsp; &nbsp; ]
 +
&nbsp; &nbsp; &nbsp; }
 +
&nbsp; &nbsp; },
 +
&nbsp; &nbsp; "commCmd": 534,
 +
&nbsp; &nbsp; "requestID": 30002,
 +
&nbsp; &nbsp; "agentID": "OPCUAClient",
 +
&nbsp; &nbsp; "handlerName": "OPCUAClient",
 +
&nbsp; &nbsp; "sendTS": 1587353254699
 +
&nbsp; }
 +
}</pre>
 +
 
 +
== Get Sensor Data ==
 +
 
 +
*Description: Server can send mqtt message to get sensor data value.
 +
*Type: Request
 +
*Direction: Server -> Agent
 +
*Topic: /cagent/admin/&lt;devID&gt;/agentcallbackreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 
  {   
 
  {   
 
   "susiCommData":{   
 
   "susiCommData":{   
Line 166: Line 349:
 
  }
 
  }
  
Description: Agent will reply its data value.
+
*Description: Agent will reply its data value.
Type: Reply
+
*Type: Reply
Direction: Agent -> Server
+
*Direction: Agent -> Server
Topic: /cagent/admin/<devID>/agentactionreq
+
*Topic: /cagent/admin/&lt;devID&gt;/agentactionreq
QoS: 0
+
*QoS: 0
Retained: 0
+
*Retained: 0
Payload:
+
*Payload:
 +
 
 
  {   
 
  {   
 
   "susiCommData":{   
 
   "susiCommData":{   
Line 189: Line 373:
 
   }
 
   }
 
  }
 
  }
==Set Sensor Data==
+
 
 +
== Set Sensor Data ==
 +
 
 +
*Description: Server can send mqtt message to set sensor data value.
 +
*Type: Request
 +
*Direction: Server -> Agent
 +
*Topic: /cagent/admin/&lt;devID&gt;/agentcallbackreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 +
 +
  "susiCommData":{ 
 +
      "sensorIDList":{ 
 +
        "e":[ 
 +
            { 
 +
              "sv":"SenHub1",
 +
              "n":"SenHub/Info/Name"
 +
            }
 +
        ]
 +
      },
 +
      "sessionID":"4DDF0B6DE2773176095F55E8C930507A",
 +
      "commCmd":525,
 +
      "requestID":0,
 +
      "agentID":"",
 +
      "handlerName":"SenHub",
 +
      "sendTS":1466088605
 +
  }
 +
}
 +
 
 +
*Description: Agent will reply its result.
 +
*Type: Reply
 +
*Direction: Agent -> Server
 +
*Topic: /cagent/admin/&lt;devID&gt;/agentactionreq
 +
*QoS: 0
 +
*Retained: 0
 +
*Payload:
 +
 
 +
 +
  "susiCommData":{ 
 +
      "commCmd":526,
 +
      "handlerName":"SenHub",
 +
      "sessionID":"4DDF0B6DE2773176095F55E8C930507A",
 +
      "sensorInfoList":{ 
 +
        "e":[ 
 +
            { 
 +
              "n":"/Info/Name",
 +
              "sv":"SenHub1",
 +
              "StatusCode":200
 +
            }
 +
        ]
 +
      }
 +
  }
 +
}
 +
 
 +
== EventNotify ==
 +
 
 +
*Description:Event Notify
 +
*Type: Auto update
 +
*Direction: Agent -> Server
 +
*Topic: /cagent/admin/&lt;devID&gt;/eventnotify
 +
*QoS:&nbsp;?
 +
*Retained:&nbsp;?
 +
*Payload:
 +
<pre>{ 
 +
  "susiCommData":{ 
 +
      "commCmd":2059,
 +
      "requestID":2001,
 +
      "agentID":"000014DAE996BE04",
 +
      "handlerName":"general",
 +
      "sendTS":1453356274,
 +
      "eventnotify": {
 +
            "subtype": "predict",
 +
            "msg": "Hard disk long-term operation in more than 40°C or vibration environment.",
 +
            "severity": 4,
 +
            "handler": "HDD_PMQ",
 +
            "extMsg": {
 +
                "n": "WDC WD3200BUCT-63TWBY0",
 +
                "eventID":"e2"
 +
            }
 +
        } 
 +
&nbsp;  }
 +
}</pre>
 +
 
 +
 
 +
<pre>severity:
 +
    Severity_Emergency = 0,
 +
    Severity_Alert    = 1,
 +
    Severity_Critical  = 2,
 +
    Severity_Error    = 3,
 +
    Severity_Warning  = 4,
 +
    Severity_Informational = 5,
 +
    Severity_Debug    = 6,
 +
 
 +
subtype:
 +
    THRESHOLD_CHECK_INFO
 +
    THRESHOLD_CHECK_ERROR
 +
</pre>
 +
 
 +
== [[Connectivity/AdvHeartBeat|AdvHeartBeat]] ==

Latest revision as of 06:56, 17 February 2023

Overview

Introduction for "WISEAgent communication protocol". WISEAgent communication protocol is base on standard MQTT protocol. We also define Advantech IoT Topic and message in JSON format. Follow standard to design our [Sensor Format in JSON ]

Protocol

Connect

  • Description: Agent Client sends the "Connect Info" to RMM Server for on-line notification.
  • Type: Info
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/agentinfoack
  • QoS: 2
  • Retained: 0
  • Payload:
{
  "susiCommData": {
    	"devID":"0017000E40000001",
    	"hostname":"AAA",
    	"sn":"0017000E40000001",
    	"mac":"0017000E40000001",
    	"version":"3.1.23",
    	"type":"SenHub",
    	"product":"WISE-1020",
    	"manufacture":"",
    	"status":"1",
    	"commCmd":1,
    	"requestID":30002,
    	"agentID":"0017000E40000001",
    	"handlerName":"general",
    	"sendTS":160081026
   }
}

Disconnect

  • Description: Agent Client sends the "Disconnect Info" to Server for off-line notification.
  • Type: Info
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/agentinfoack
  • QoS: 2
  • Retained: 0
  • Payload:
{
  "susiCommData": {
    	"devID":"0017000E40000001",
    	"hostname":"AAA",
    	"sn":"0017000E40000001",
    	"mac":"0017000E40000001",
    	"version":"3.1.23",
    	"type":"SenHub",
    	"product":"WISE-1020",
    	"manufacture":"",
    	"status":"0",
    	"commCmd":1,
    	"requestID":30002,
    	"agentID":"0017000E40000001",
    	"handlerName":"general",
    	"sendTS":160081026
   }
}

Will Message

  • Description: While Client lost connection or keep-alive timeout, the will message will send to the client that subscribe the topic
  • Type: Info
  • Direction: Agent -> Broker
  • Topic: /cagent/admin/devId/willmessage
  • QoS: 0
  • Retained: 0
  • Payload:
{
    "susiCommData": {
        "devID": "000014DAE996BE04",
        "hostname": "PC001104",
        "sn": "14DAE996BE04",
        "mac": "14DAE996BE04",
        "version": "1.0.0.0",
        "type": "IPC",
        "product": "",
        "manufacture": "",
        "account": "anonymous",
        "password": "",
        "status": 0,
        "commCmd": 1,
        "requestID": 21,
        "agentID": "000014DAE996BE04",
        "handlerName": "general",
        "sendTS": 1423536737
    }
}

OS Info

  • Description: Agent Client sends the OS Info" to RMM Server for device OS information.
  • Type: Info
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/agentactionreq
  • QoS: 0
  • Retained: 0
  • Payload:
{
  "susiCommData":{
     "osInfo":
      {
        "cagentVersion":"3.1.23",
        "cagentType":"IoTGW",
        "osVersion":"SnailOS",
        "biosVersion":"",
        "platformName":"",
        "processorName":"SnailGW",
        "osArch":"SnailX86",
        "totalPhysMemKB":123,
        "macs":"000E40ABCDEF",
        "IP":"192.168.0.100"
     },
     "commCmd":116,
     "requestID":109,
     "agentID":"0000000E40ABCDEF",
     "handlerName":"general",
     "sendTS":1466730390
   }
}


Info or Update Device's Capability

  • Description: Agent will send it's capability to Server for description all resource.
  • Type: Auto update
  • Direction: Agent-> Server
  • Topic: /cagent/admin/<devID>/agentactionreq
  • QoS: 0
  • Retained: 0
  • Payload: 

Example: SenHub's Capability

{
  "susiCommData":{
    "infoSpec": {
        "SenHub": {
            "SenData": {"e":[ {"n":"Temperature","u":"Cel","v":0.000000,"min":-100.000000,"max":200.000000,"asm":"r","type":"d","rt":"ucum.Cel","st":"ipso","exten":""},
                              {"n":"Humidity","u":"%","v":0.000000,"min":0.000000,"max":100.000000,"asm":"r","type":"d","rt":"ucum.%","st":"ipso","exten":""},
                              {"n":"GPIO1","u":"","bv":0,"min":0.000000,"max":1.000000,"asm":"r","type":"b","rt":"","st":"ipso","exten":""},
                              {"n":"GPIO2","u":"","bv":0,"min":0.000000,"max":1.000000,"asm":"r","type":"b","rt":"","st":"ipso","exten":""}
                            ],
            "bn":"SenData"
            },
            "Info": {"e":[{"n":"Name","sv":"SenHub1","asm":"rw"},
                          {"n":"sw","sv":"1.0.00","asm":"r"}
                         ],
            "bn":"Info"
           },
           "Net": {"e":[{"n":"sw","sv":"1.0.00","asm":"r"},
                        {"n":"Neighbor","sv":"","asm":"r"},
                        {"n":"Health","v":"100.000000","asm":"r"}
                       ],
            "bn":"Net"
           }
       }
   },
   "commCmd":2052,
   "requestID":2001,
   "agentID":"0017000E40000001",
   "handlerName":"general",
   "sendTS":160081024
  }
}

Eable Auto Update 

  • Description: Server can send start auto report command to Agent
  • Type: Auto report
  • Direction: Server -> Agent
  • Topic: /cagent/admin/<device>/agentcallbackreq
  • Broadcast Topic: /cagent/admin/broadcast/agentctrl
  • QoS: 0
  • Retained: 0
  • Payload:
{
   "susiCommData": {
      "commCmd": 2053,
      "requestItems": {"All":{}},
      "autoUploadIntervalSec": 10,
      "handlerName": "general"
   }
}
  • Description: Agent reply 
  • Type: Reply of auto report command
  • Direction: Server -> Agent
  • Topic: /cagent/admin/<device>/agentactionreq
  • QoS: 0
  • Retained: 0
  • Payload:
{
  "susiCommData": {
    "result": "SUCCESS",
    "dataFlow": "general/NetMonitor",
    "seq": "70_1611629702692",
    "srcTs": 1611629702692,
    "commCmd": 2054,
    "agentID": "NetMonitor",
    "handlerName": "general",
    "sendTS": : 1611629702692
  }
}

Stope Auto Update 

  • Description: Server can send stop auto report command to Agent
  • Type: Auto update
  • Direction: Server -> Agent
  • Topic: /cagent/admin/<device>/agentcallbackreq
  • Broadcast Topic: /cagent/admin/broadcast/agentctrl
  • QoS: 0
  • Retained: 0
  • Payload:
{
  "susiCommData": {
    "requestID": 1001,
    "catalogID": 4,
    "commCmd": 2056,
    "handlerName": "general",
    "requestItems": {
      "All": {}
    }
  }
}

Auto Update Sensor Data Value

  • Description: Agent will update latest value to server.
  • Type: Auto update
  • Direction: Agent-> Server
  • Topic: /cagent/admin/<devID>/deviceinfo
  • QoS: 0
  • Retained: 0
  • Payload:
{  
  "susiCommData":{  
     "data":{  
        "SenHub":{  
           "SenData":{  
              "e":[{"n":"Temperature","v":1},
                   {"n":"Humidity","v":57},
                   {"n":"GPIO1","bv":0},
                   {"n":"GPIO2","bv":0}],
              "bn":"SenData"
           },
           "ver":1
        }
     },
     "commCmd":2055,
     "requestID":2001,
     "agentID":"0017000E40000001",
     "handlerName":"general",
     "sendTS":160081031
  }
}

Start Monitor Request

  • Description: Server send the start monitor requestto Agent to trigger a plugin to report data with reply topic.
  • Type: Auto update
  • Direction: Server -> Agent
  • Topic: /cagent/admin/<devID>/agentcallbackreq
  • QoS: 0
  • Retained: 0
  • Payload:
{
  "susiCommData": {
    "commCmd": 533,
    "catalogID": 4,
    "requestID": 10,
    "autoUploadIntervalMs": 10000,
    "autoUploadTimeoutMs": 30000
  }
}
  • Description: Agent will reply sensor data every autoUploadIntervalMs ( millisecond ) duration autoUploadTimeoutMs.
  • Type: Reply
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/agentactionreq
  • QoS: 0
  • Retained: 0
  • Payload: Refer to Auto Update Sensor Data Value
{
  "susiCommData": {
    "OPCUAClient": {
      "info": {
        "bn": "info",
        "e": [
          {
            "n": "type",
            "sv": "Protocol-Converter",
            "asm": "r"
          },
          {
            "n": "name",
            "sv": "OPCUAClient",
            "asm": "r"
          }
        ]
      }
    },
    "commCmd": 534,
    "requestID": 30002,
    "agentID": "OPCUAClient",
    "handlerName": "OPCUAClient",
    "sendTS": 1587353254699
  }
}

Get Sensor Data

  • Description: Server can send mqtt message to get sensor data value.
  • Type: Request
  • Direction: Server -> Agent
  • Topic: /cagent/admin/<devID>/agentcallbackreq
  • QoS: 0
  • Retained: 0
  • Payload:
{  
  "susiCommData":{  
     "sessionID":"2746E3B65BAB115338B9668CDC5C35C4",
     "sensorIDList":{  
        "e":[  
           {  
              "n":"SenHub/Info/sw"
           }
        ]
     },
     "commCmd":523,
     "requestID":0,
     "agentID":"",
     "handlerName":"SenHub",
     "sendTS":1466057267
  }
}
  • Description: Agent will reply its data value.
  • Type: Reply
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/agentactionreq
  • QoS: 0
  • Retained: 0
  • Payload:
{  
  "susiCommData":{  
     "commCmd":524,
     "handlerName":"SenHub",
     "sessionID":"2746E3B65BAB115338B9668CDC5C35C4",
     "sensorInfoList":{  
        "e":[  
           {  
              "n":"/Info/sw",
              "sv":"1.0.00",
              "StatusCode":200
           }
        ]
     }
  }
}

Set Sensor Data

  • Description: Server can send mqtt message to set sensor data value.
  • Type: Request
  • Direction: Server -> Agent
  • Topic: /cagent/admin/<devID>/agentcallbackreq
  • QoS: 0
  • Retained: 0
  • Payload:
{  
  "susiCommData":{  
     "sensorIDList":{  
        "e":[  
           {  
              "sv":"SenHub1",
              "n":"SenHub/Info/Name"
           }
        ]
     },
     "sessionID":"4DDF0B6DE2773176095F55E8C930507A",
     "commCmd":525,
     "requestID":0,
     "agentID":"",
     "handlerName":"SenHub",
     "sendTS":1466088605
  }
}
  • Description: Agent will reply its result.
  • Type: Reply
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/agentactionreq
  • QoS: 0
  • Retained: 0
  • Payload:
{  
  "susiCommData":{  
     "commCmd":526,
     "handlerName":"SenHub",
     "sessionID":"4DDF0B6DE2773176095F55E8C930507A",
     "sensorInfoList":{  
        "e":[  
           {  
              "n":"/Info/Name",
              "sv":"SenHub1",
              "StatusCode":200
           }
        ]
     }
  }
}

EventNotify

  • Description:Event Notify
  • Type: Auto update
  • Direction: Agent -> Server
  • Topic: /cagent/admin/<devID>/eventnotify
  • QoS: ?
  • Retained: ?
  • Payload:
{  
   "susiCommData":{  
      "commCmd":2059,
      "requestID":2001,
      "agentID":"000014DAE996BE04",
      "handlerName":"general",
      "sendTS":1453356274,
      "eventnotify": {
            "subtype": "predict",
            "msg": "Hard disk long-term operation in more than 40°C or vibration environment.",
            "severity": 4,
            "handler": "HDD_PMQ",
            "extMsg": {
                "n": "WDC WD3200BUCT-63TWBY0",
                "eventID":"e2"
            }
        }  
    }
}


severity:
     Severity_Emergency = 0,
     Severity_Alert     = 1,
     Severity_Critical  = 2,
     Severity_Error     = 3,
     Severity_Warning   = 4,
     Severity_Informational = 5,
     Severity_Debug     = 6,

subtype: 
    THRESHOLD_CHECK_INFO
    THRESHOLD_CHECK_ERROR

AdvHeartBeat