Change the stream definition for rule false true false srv 127.0.0.1 = rest_port 9081 = mqtt_srv 127.0.0.1 = continue false 1 1 1 false 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 The connections true false { "sql" : "create stream demo (temperature float, light string) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/+/messages\",STRICT_VALIDATION=\"true\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 true false { "id": "rule1", "sql": "SELECT light FROM demo", "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 rule1 was created Assertion.response_data true 16 true false = ${srv} ${rest_port} /rules/rule1/status GET true false true false $.source_demo_0_records_in_total 0 true false false false devices/${device_id}/messages 0 false String 1024 {"temperature": ${__Random(1,100,)}, "humidity" : ${__Random(1,100,)}} true false = ${srv} ${rest_port} /rules/rule1/status GET true false true false $.source_demo_0_records_in_total 1 true false false false $.sink_mqtt_0_0_records_in_total 1 true false false false true false = ${srv} ${rest_port} /streams/demo DELETE true false true false Stream demo is dropped. Assertion.response_data false 16 true false { "sql" : "create stream demo (temperature float, humidity bigint, light bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/+/messages\",STRICT_VALIDATION=\"true\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 500 false false true false = ${srv} ${rest_port} /streams/demo DELETE true false true false Stream demo is dropped. Assertion.response_data false 16 true false { "sql" : "create stream demo (temperature float, humidity bigint, light bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/+/messages\",STRICT_VALIDATION=\"true\" )" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 devices/${device_id}/messages 0 false String 1024 {"temperature": ${__Random(1,100,)}, "humidity" : ${__Random(1,100,)}, "light" : ${__Random(1,100,)}} 500 false false true false = ${srv} ${rest_port} /rules/rule1/restart POST true false true false Rule rule1 was restarted Assertion.response_data false 16 devices/${device_id}/messages 0 false String 1024 {"temperature": ${__Random(1,100,)}, "humidity" : ${__Random(1,100,)}, "light" : ${__Random(1,100,)}} 500 true false = ${srv} ${rest_port} /streams/demo DELETE true false true false Stream demo is dropped. Assertion.response_data false 16 true false = ${srv} ${rest_port} /rules/rule1 DELETE true false true false Rule rule1 is dropped. Assertion.response_data false 16 continue false 3 1 1 false change_stream_rule.txt result false , false true false shareMode.all 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 devices/result 0 false true number of received messages 1 ${result} Assertion.response_data false 16