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 table stateTable (state bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"messages/state\", TYPE=\"mqtt\" )" } = ${srv} ${rest_port} /tables POST true false true false Table stateTable is created. Assertion.response_data true 16 true false { "sql" : "create stream demo (temperature bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"messages/iot\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 true false { "id": "ruleTableCont", "sql": "SELECT temperature FROM demo INNER JOIN stateTable WHERE stateTable.state= 1 AND temperature > 30", "actions": [ { "mqtt": { "server": "tcp://${mqtt_srv}:1883", "topic": "devices/result", "qos": 1, "clientId": "demo_001" } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule ruleTableCont was created Assertion.response_data true 16 ${srv} ${rest_port} /rules/ruleTableCont/status GET true false true false $.source_demo_0_records_in_total 0 true false false false true 13 , iot_data_multi_topics.txt false false true shareMode.thread false topic,num,state messages/${topic} 0 false String 1024 {"temperature":${num},"state":${state}} false ${srv} ${rest_port} /rules/ruleTableCont/status GET true false true false $.source_stateTable_0_records_in_total 4 true false false false $.source_demo_0_records_in_total 9 true false false false $.sink_mqtt_0_0_records_out_total 3 true false false false 5000 ${srv} ${rest_port} /rules/ruleTableCont DELETE true false true false Rule ruleTableCont 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 ${srv} ${rest_port} /tables/stateTable DELETE true false true false Table stateTable is dropped. Assertion.response_data false 16 500 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 0 false true number of received messages 1 $[0].temperature ${temperature} true false false false , table_cont_result_data.txt false false false shareMode.thread true temperature