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":"mirror", "file":"http://127.0.0.1:9090/plugins/mirror.zip" } = ${srv} ${rest_port} /plugins/portables POST true false true false 201 Assertion.response_code true 16 500 ${srv} ${rest_port} /plugins/portables/mirror GET true false true false mirror Assertion.response_data true 16 true false { "sql" : "CREATE STREAM ext (count bigint) WITH (DATASOURCE=\"ext\", FORMAT=\"JSON\", TYPE=\"random\",CONF_KEY=\"ext\")" } = ${srv} ${rest_port} /streams POST true false true false Stream ext is created. Assertion.response_data true 16 true false { "id": "ruleExtG", "sql": "SELECT * FROM ext", "actions": [{ "file": { "path": "cache" } }] } = ${srv} ${rest_port} /rules POST true false true false Rule ruleExtG was created Assertion.response_data true 16 500 500 ${srv} ${rest_port} /rules/ruleExtG/status GET true false true false 300 fileout $.sink_file_0_0_records_out_total true String jsonString = vars.get("fileout"); int count = jsonString.toInteger() log.info ("The file out metric " + count); if (count<=0) { AssertionResult.setFailureMessage("The sink output is 0"); AssertionResult.setFailure(true); } groovy ${srv} ${rest_port} /rules/ruleExtG DELETE true false true false Rule ruleExtG is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams/ext DELETE true false true false Stream ext is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /plugins/portables/mirror DELETE true false true false portable plugin mirror is deleted Assertion.response_data true 16 false false true false { "name":"pysam", "file":"http://127.0.0.1:9090/plugins/pysam.zip" } = ${srv} ${rest_port} /plugins/portables POST true false true false 201 Assertion.response_code true 16 500 ${srv} ${rest_port} /plugins/portables/pysam GET true false true false pysam Assertion.response_data true 16 true false { "sql" : "CREATE STREAM ext2 () WITH (DATASOURCE=\"ext2\", FORMAT=\"JSON\", TYPE=\"pyjson\")" } = ${srv} ${rest_port} /streams POST true false true false Stream ext2 is created. Assertion.response_data true 16 true false { "id": "ruleExtP", "sql": "SELECT * FROM ext2", "actions": [{ "print": { } }] } = ${srv} ${rest_port} /rules POST true false true false Rule ruleExtP was created Assertion.response_data true 16 500 ${srv} ${rest_port} /rules/ruleExtP/status GET true false true false fileout $.sink_print_0_0_records_out_total true String jsonString = vars.get("fileout"); int count = jsonString.toInteger() log.info ("The file out metric " + count); if (count<=0) { AssertionResult.setFailureMessage("The sink output is 0"); AssertionResult.setFailure(true); } groovy ${srv} ${rest_port} /rules/ruleExtP DELETE true false true false Rule ruleExtP is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams/ext2 DELETE true false true false Stream ext2 is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /plugins/portables/pysam DELETE true false true false portable plugin pysam 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/