false true false srv 127.0.0.1 = rest_port 9081 = mqtt_srv 127.0.0.1 = continue false 1 1 1 false true false saveConfig true true true true true true true false true true false false false true false false false true 0 true true true true true false false ${mqtt_srv} 1883 3.1 10 false 10 TCP false conn_ true 300 0 0 true true false { "sql" : "create stream demo (temperature float, humidity bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/+/messages\", SHARED=\"true\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 true false { "id": "ruleShared1", "sql": "SELECT * FROM demo WHERE temperature > 30", "actions": [ { "mqtt": { "server": "tcp://${mqtt_srv}:1883", "topic": "devices/result/temperature", "qos": 1, "clientId": "demo_001" } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule ruleShared1 was created Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleShared1/status GET true false true false $.source_demo_0_records_in_total 0 true false false false true false { "id": "ruleShared2", "sql": "SELECT * FROM demo WHERE humidity > 50", "actions": [ { "mqtt": { "server": "tcp://${mqtt_srv}:1883", "topic": "devices/result/humidity", "qos": 1, "clientId": "demo_002" } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule ruleShared2 was created Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleShared2/status GET true false true false $.source_demo_0_records_in_total 0 true false false false true false { "id": "ruleShared3", "sql": "SELECT * FROM demo WHERE temperature < 30 and humidity < 50", "actions": [ { "mqtt": { "server": "tcp://${mqtt_srv}:1883", "topic": "devices/result/both", "qos": 1, "clientId": "demo_003" } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule ruleShared3 was created Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleShared3/status GET true false true false $.source_demo_0_records_in_total 0 true false false false ${srv} ${rest_port} /rules/ruleShared1/restart POST true false true false Rule ruleShared1 was restarted Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleShared1/status GET true false true false $.source_demo_0_records_in_total 0 true false false false ${srv} ${rest_port} /rules/ruleShared2/restart POST true false true false Rule ruleShared2 was restarted Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleShared2/status GET true false true false $.source_demo_0_records_in_total 0 true false false false ${srv} ${rest_port} /rules/ruleShared3/restart POST true false true false Rule ruleShared3 was restarted Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleShared3/status GET true false true false $.source_demo_0_records_in_total 0 true false false false true 10 , iot_data.txt false false true shareMode.thread false device_id,temperature,humidity devices/${device_id}/messages 0 false String 1024 {"temperature": ${temperature}, "humidity" : ${humidity}} false ${srv} ${rest_port} /rules/ruleShared1/status GET true false true false $.source_demo_0_records_in_total 10 true false false false $.sink_mqtt_0_0_records_in_total 6 true false false false ${srv} ${rest_port} /rules/ruleShared1 DELETE true false true false Rule ruleShared1 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /rules/ruleShared2/status GET true false true false $.source_demo_0_records_in_total 10 true false false false $.sink_mqtt_0_0_records_in_total 2 true false false false ${srv} ${rest_port} /rules/ruleShared2 DELETE true false true false Rule ruleShared2 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /rules/ruleShared3/status GET true false true false $.source_demo_0_records_in_total 10 true false false false $.sink_mqtt_0_0_records_in_total 3 true false false false ${srv} ${rest_port} /rules/ruleShared3 DELETE true false true false Rule ruleShared3 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams/demo DELETE true false true false Stream demo is dropped. Assertion.response_data false 16 1000 continue false 6 1 1 false true false saveConfig true true true true true true true false true true false false false true false false false true 0 true true true true true ${mqtt_srv} 1883 3.1 10 false 10 TCP false conn_ true 300 0 0 true devices/result/temperature 0 false true number of received messages 1 $[0].temperature ${temperature} true false false false $[0].humidity ${humidity} true false false false , select_condition_iot_data.txt false false true shareMode.thread false device_id,temperature,humidity continue false 2 1 1 false true false saveConfig true true true true true true true false true true false false false true false false false true 0 true true true true true ${mqtt_srv} 1883 3.1 10 false 10 TCP false conn_ true 300 0 0 true devices/result/humidity 0 false true number of received messages 1 $[0].temperature ${temperature} true false false false $[0].humidity ${humidity} true false false false , select_condition_iot_data2.txt false false true shareMode.thread false device_id,temperature,humidity continue false 3 1 1 false true false saveConfig true true true true true true true false true true false false false true false false false true 0 true true true true true ${mqtt_srv} 1883 3.1 10 false 10 TCP false conn_ true 300 0 0 true devices/result/both 0 false true number of received messages 1 $[0].temperature ${temperature} true false false false $[0].humidity ${humidity} true false false false , select_condition_iot_data3.txt false false true shareMode.thread false device_id,temperature,humidity