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 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 device1 (temperature float, humidity bigint, ts bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/1/messages\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream device1 is created. Assertion.response_data true 16 true false { "sql" : "create stream device2 (temperature float, humidity bigint, ts bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/2/messages\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream device2 is created. Assertion.response_data true 16 true false {"sql" : "create stream sensorAll () WITH (DATASOURCE=\"result/source/+\", FORMAT=\"JSON\", TYPE=\"memory\", TIMESTAMP=\"ts\")"} = ${srv} ${rest_port} /streams POST true false true false Stream sensorAll is created. Assertion.response_data true 16 true false { "id": "rule1", "sql": "SELECT * FROM device1 WHERE humidity > 30", "actions": [{ "memory": { "topic": "result/source/rule1" } }] } = ${srv} ${rest_port} /rules POST true false true false Rule rule1 was created Assertion.response_data true 16 true false { "id": "rule2", "sql": "SELECT * FROM device2 WHERE temperature > 26", "actions": [{ "memory": { "topic": "result/source/rule2" } }] } = ${srv} ${rest_port} /rules POST true false true false Rule rule2 was created Assertion.response_data true 16 true false { "id": "ruleFinal", "sql": "SELECT concat(\"final/\", meta(topic)) as t, avg(temperature) as temp, window_end() as ts FROM sensorAll GROUP BY TumblingWindow(ss, 2), t", "actions": [{ "mqtt": { "server": "tcp://${mqtt_srv}:1883", "sendSingle": true, "topic": "{{.t}}" } }], "options": { "isEventTime": true, "lateTolerance" : 0 } } = ${srv} ${rest_port} /rules POST true false true false Rule ruleFinal was created Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleFinal/status GET true false true false $.source_sensorAll_0_records_in_total 0 true false false false true 15 , iot_data_ts.txt false false true shareMode.thread false device_id,ts,temperature,humidity devices/${device_id}/messages 0 false String 1024 {"temperature": ${temperature}, "humidity" : ${humidity},"ts":${ts}} false ${srv} ${rest_port} /rules/ruleFinal/status GET true false true false $.sink_mqtt_0_0_records_in_total 3 true false false false 5000 ${srv} ${rest_port} /rules/rule1 DELETE true false true false Rule rule1 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /rules/rule2 DELETE true false true false Rule rule2 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /rules/ruleFinal DELETE true false true false Rule ruleFinal is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams/device1 DELETE true false true false Stream device1 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams/device2 DELETE true false true false Stream device2 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams/sensorAll DELETE true false true false Stream sensorAll is dropped. Assertion.response_data false 16 500 continue false 1 1 1 false true false saveConfig true true 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 final/result/source/rule1 0 false true number of received messages 1 $.temp 24.349999999999998 true false false false $.ts 1541152492000 true false false false continue false 1 1 1 false true false saveConfig true true 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 final/result/source/rule2 0 false true number of received messages 1 $.temp 27.03333333333333 true false false false $.ts 1541152490000 true false false false final/result/source/rule2 0 false true number of received messages 1 $.temp 27.025000000000002 true false false false $.ts 1541152492000 true false false false