Difference between revisions of "IoTGateway/DataProcess"
From ESS-WIKI
Eric.liang (talk | contribs) |
Eric.liang (talk | contribs) (→SQL Structure and Define for Handler) |
||
| Line 177: | Line 177: | ||
| − | + | '''<big>Protocol Params in JSON Format</big>''' | |
| − | |||
| − | Protocol Params in JSON Format | ||
| − | |||
{ | { | ||
"Protocol":"MQTT", | "Protocol":"MQTT", | ||
"MQTT":{ | "MQTT":{ | ||
| − | + | "QoS":2, | |
| − | + | "Retain":0 | |
} | } | ||
} | } | ||
| − | + | =Data Extend Information and SQL Structure for Handler to Manager= | |
| − | + | ||
| − | + | '''<big>SQL Params structure. This stuucture is designed for Hanlder pass its log behavior.</big>''' | |
| − | + | typedef struct SQLParams | |
| − | + | { | |
| − | + | int nAction; // 0: Insert or Update, 1: Delete, 2: Query | |
| − | + | char *pszPrimaryKey; // NULL => Auto Index | |
| + | char **pszOutDataPoint; // Pass this point to save result of query | ||
| + | char *pszGeneralInfo; // | ||
| + | int *int; // status code | ||
| + | void *pExtend1; | ||
| + | void *pExtend2; | ||
| + | }SQL_PARAMS, SQL_Params; | ||
| + | |||
| + | |||
| + | '''<big>Data extened Information Structure. Handler can add more information while sending data to WISE Manager.</big>''' | ||
| + | typedef struct DataExInfo | ||
| + | { | ||
| + | int nVer; // Struct version, ( 1 ) | ||
| + | void *pSqlParams; // address of SQL parameters structure | ||
| + | void *pExtend1; // Reserved | ||
| + | void *pExtend2; // Reserved | ||
| + | }DATAEX_INFO, DataEx_Info; | ||
Revision as of 04:47, 6 September 2016
- Data Format and SQL Field is designed for Data e-motion, Mqtt Reliability Data Channel.
SQL Field
| SQLite Table Fields ( Auto Index) | |||||
| Item | Field Name | Type | Need | Format | Example |
| 1 | Key | Unsigned Int | Must | 6886 (serial number) | |
| 2 | SecondKey | Text | Optional | Default: Hanle Name: SUSHandler | |
| 3 | Protocol_Param | Text | Optional | JSON | {"Type":"MQTT","TypeId":1, "QoS":0 } |
| 4 | Message | Text | Optional | {IoTGW { …. } ) | |
| 5 | Send | Flag | Optional | 0 or 1 | 1 or 0 |
| 6 | Time | Unsigned Int | Must | 33325 ( UTC in sec ) | |
| 7 | General | Text | Optional | any type format | |
| SQLite Table Fields ( User Assign Key ) | |||||
| Item | Field Name | Type | Need | Format | Example |
| 1 | Key | Text | Must | /cagent/admin/infoack | |
| 2 | SecondKey | Text | Optional | Default: Hanle Name: SUSHandler | |
| 3 | Protocol_Param | Text | Optional | JSON | {"Type":"MQTT","TypeId":1, "QoS":0 } |
| 4 | Message | Text | Optional | {IoTGW { …. } ) | |
| 5 | Send | Flag | Optional | 0 or 1 | 1 or 0 |
| 6 | Time | Unsigned Int | Must | 33325 ( UTC in sec ) | |
| 7 | General | Text | Optional | any type format | |
| SQLite Methods | |||||
| Item | Method | Note | |||
| 1 | Insert | *by Primary key
*by Second key ( ex: HandlerName ) ( primary key => auto index ) | |||
| 2 | Update | by Primary key | |||
| 3 | Query | * by Primary key
* by Search rules ( like or updatetime or latest item / order by ? (time ...) ) * All ( order by time ) | |||
| 4 | Clean | *by Primary Key
*by Search rules ( like or updatetime or latest item / order by ? (time ...) ) *All items of Table | |||
| 5 | Create Table | *AutoIndex
*UniqueKey | |||
Protocol Params in JSON Format
{
"Protocol":"MQTT",
"MQTT":{
"QoS":2,
"Retain":0
}
}
Data Extend Information and SQL Structure for Handler to Manager
SQL Params structure. This stuucture is designed for Hanlder pass its log behavior.
typedef struct SQLParams
{
int nAction; // 0: Insert or Update, 1: Delete, 2: Query
char *pszPrimaryKey; // NULL => Auto Index
char **pszOutDataPoint; // Pass this point to save result of query
char *pszGeneralInfo; //
int *int; // status code
void *pExtend1;
void *pExtend2;
}SQL_PARAMS, SQL_Params;
Data extened Information Structure. Handler can add more information while sending data to WISE Manager.
typedef struct DataExInfo
{
int nVer; // Struct version, ( 1 )
void *pSqlParams; // address of SQL parameters structure
void *pExtend1; // Reserved
void *pExtend2; // Reserved
}DATAEX_INFO, DataEx_Info;