窗口数据作为一个新流，针对这个新流的规则里面使用自定义函数接受的还是单个数据，不是完整一个窗口数据

eKuiper
1

场景是
A流使用窗口做成一个新流B

B里面使用规则 select 函数(*) from B

函数里面接受的还是单个单个数据，不是整体的一窗口数据

2

窗口可以看成一个多个行的数据库表。SQL 里的聚合函数 count, avg 等才是多行聚合成一行。普通函数都是作用于单行的。

3

A流使用 类似 select * from xx group by tumblingwindow(ss, xx) ，并且使用sendSingle = false 到一个新流

按我理解，这样每次到一个新流，应该是一个窗口数据，并且是数组过去的

那么再新流使用规则，里面的每条数据，应该是窗口数据，并且是数组

4

我们场景是这样的

聚合窗口数据，丢给python的服务处理后，处理后数据再吐回ekuiper进行下一个规则继续清洗

看文档目前想让python处理，并且继续进行流式处理，好像只能使用函数

5

select collect(*) as data 这样应该能满足预期

6

完美