false true false srv 127.0.0.1 = rest_port 9081 = 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 true false { "name":"zmq", "file":"http://127.0.0.1:9090/plugins/zmq.zip" } = ${srv} ${rest_port} /plugins/sources POST true false true false 201 Assertion.response_code true 16 500 ${srv} ${rest_port} /plugins/sources/zmq GET true false true false zmq Assertion.response_data true 16 true false { "sql" : "create stream demo (humidity bigint, temperature bigint) WITH (DATASOURCE=\"events\", FORMAT=\"JSON\", TYPE=\"zmq\")" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 true false { "id": "rule1", "sql": "SELECT * FROM demo WHERE humidity = 55", "actions": [ { "rest": { "url": "http://127.0.0.1:9090/alert", "method": "post", "dataTemplate": "{\"content\":{{json .}}}", "sendSingle": true } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule rule1 was created Assertion.response_data true 16 false 0 test/plugins/pub/zmq_pub ${__property(fvt,,)} 500 ${srv} ${rest_port} /rules/rule1/status GET true false true false $.sink_rest_0_0_records_in_total 2 true false false false 1000 ${srv} ${rest_port} /rules/rule1 DELETE true false true false Rule rule1 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} /plugins/sources/zmq DELETE true false true false sources plugin zmq is deleted Assertion.response_data true 16 500 false false true false { "name":"tdengine", "file":"http://127.0.0.1:9090/plugins/tdengine.zip" } = ${srv} ${rest_port} /plugins/sinks POST true false true false 201 Assertion.response_code true 16 500 ${srv} ${rest_port} /plugins/sinks/tdengine GET true false true false tdengine Assertion.response_data true 16 true false { "sql" : "create stream demo (humidity bigint, temperature bigint) WITH (DATASOURCE=\"events\", FORMAT=\"JSON\", TYPE=\"mqtt\")" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 true false { "id": "rule1", "sql": "SELECT * FROM demo", "actions": [ { "tdengine": { "provideTs": false, "tsFieldName": "time", "port": 0, "ip": "taos", "user": "root", "password": "taosdata", "database": "sensor", "table": "t1", "fields": [ "temperature","humidity" ] } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule rule1 was created Assertion.response_data true 16 500 ${srv} ${rest_port} /rules/rule1/status GET true false true false $.sink_tdengine_0_0_records_in_total 0 true false false false 1000 ${srv} ${rest_port} /rules/rule1 DELETE true false true false Rule rule1 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} /plugins/sinks/tdengine DELETE true false true false sinks plugin tdengine is deleted Assertion.response_data true 16 500 false false true false { "name":"sql", "file":"http://127.0.0.1:9090/plugins/sql.zip" } = ${srv} ${rest_port} /plugins/sinks POST true false true false 201 Assertion.response_code true 16 500 ${srv} ${rest_port} /plugins/sinks/sql GET true false true false sql Assertion.response_data true 16 true false { "sql" : "create stream demo (humidity bigint, temperature bigint) WITH (DATASOURCE=\"events\", FORMAT=\"JSON\", TYPE=\"mqtt\")" } = ${srv} ${rest_port} /streams POST true false true false Stream demo is created. Assertion.response_data true 16 true false { "id": "rule1", "sql": "SELECT * FROM demo", "actions": [ { "sql": { "url": "mysql://user:test@10.10.20.147/user?parseTime=true", "table": "test", "fields": ["id","name","registerTime"] } } ] } = ${srv} ${rest_port} /rules POST true false true false Rule rule1 was created Assertion.response_data true 16 500 ${srv} ${rest_port} /rules/rule1/status GET true false true false $.sink_sql_0_0_records_in_total 0 true false false false 1000 ${srv} ${rest_port} /rules/rule1 DELETE true false true false Rule rule1 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} /plugins/sinks/sql DELETE true false true false sinks plugin sql is deleted Assertion.response_data true 16 500 continue false 1 1 0 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 0 ./server ${__property(fvt,,)}/test/plugins/service/