我在 Azure 中创建了流分析作业,我想在 Power BI 中显示结果。这项工作非常简单,因为我要做的就是每 1 秒显示过去 10 分钟内发生的事件数。但是,当最后 10 分钟过去时,我需要重置计数器,这意味着我希望窗口在 10 分钟后重新启动。
我有以下选择:
- 使用持续时间为 10 分钟的翻转窗口:不,因为这不会每 1 秒显示一次结果,而是在 10 分钟后显示
- 使用 Hopping 窗口:HoppingWindow(Duration(minute, 10), Hop(second, 1))。这在前 10 分钟内有效,但在那之后就不行了,因为它会跳动 1 秒。
- 使用大小为 10 分钟的滑动窗口:否,因为当事件发生时它会滑动 10 分钟
- 使用 SessionWindow:否,因为会话窗口仅在窗口关闭时才返回输出。
我想不出一个解决方案,因为我的目标是一个窗口,它会扩展直到达到最长 10 分钟的持续时间(然后它会重新打开)并每隔一秒产生一次输出。欢迎任何帮助。