Emqx, Ekuiper.
data generated by the preceding rule. ### POST http://{{host}}/streams Content-Type: application/json {"sql": "create stream citybike_data_flatten () WITH (DATASOURCE=\"channel/data\", FORMAT=\"JSON\", TYPE=\"memory\")"} Now the data is flattened and we can continue our exploration with the data.