false true false srv 127.0.0.1 = rest_port 9081 = k_home ${__property(base,,)} = fvt ${__property(fvt,,)} = continue false 1 1 1 false true false false true false { "sql" : "create stream demo (temperature float, humidity bigint) WITH (FORMAT=\"JSON\", DATASOURCE=\"devices/+/messages\" )" } = ${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": [ { "log": {} }, { "mqtt": { "server": "tcp://127.0.0.1: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 ${srv} ${rest_port} /metrics GET true false true false # HELP kuiper_op_exceptions_total Total number of user exceptions of kuiper_op # TYPE kuiper_op_exceptions_total counter kuiper_op_exceptions_total{instance="0",op="2_project",rule="rule1",type="op"} 0 Assertion.response_data true 16 # HELP kuiper_op_records_in_total Total number of messages received by the operation of kuiper_op # TYPE kuiper_op_records_in_total counter kuiper_op_records_in_total{instance="0",op="2_project",rule="rule1",type="op"} 0 Assertion.response_data true 16 # HELP kuiper_op_records_out_total Total number of messages published by the operation of kuiper_op # TYPE kuiper_op_records_out_total counter kuiper_op_records_out_total{instance="0",op="2_project",rule="rule1",type="op"} 0 Assertion.response_data true 16 # HELP kuiper_sink_exceptions_total Total number of user exceptions of kuiper_sink # TYPE kuiper_sink_exceptions_total counter kuiper_sink_exceptions_total{instance="0",op="log_0",rule="rule1",type="sink"} 0 kuiper_sink_exceptions_total{instance="0",op="mqtt_1",rule="rule1",type="sink"} 0 Assertion.response_data true 16 # HELP kuiper_source_exceptions_total Total number of user exceptions of kuiper_source # TYPE kuiper_source_exceptions_total counter kuiper_source_exceptions_total{instance="0",op="demo",rule="rule1",type="source"} 0 Assertion.response_data true 16 ${srv} ${rest_port} /rules/rule1/status GET true false true false $.source_demo_0_records_in_total 0 true false false false ${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 500 false false ${srv} ${rest_port} / GET true false true false "os":"linux","arch":"amd64" Assertion.response_data true 16 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