...
{
"id": "rule1",
"sql": "SELECT * FROM demo GROUP BY TumblingWindow(ss, 10)",
"actions": [{
"mqtt": {
"server": "tcp://cloud:1883",
"topic": "remote",
"sendSingle":"true",
"batchSize": 100,
"lingerInterval": 100000,
"compressionType": "gzip"
}
},{
"mqtt": {
"server": "tcp://local:1883",
"topic": "local",
"sendSingle":"true"
}
}]
}
? Adapt to file format, currently splited by lines \n
? MQTT package size check
...