每次消耗新事件或流分析作业每秒输出最后 X 秒的数据

发布于 2025-01-16 22:53:35 字数 162 浏览 1 评论 0原文

我有一个 Azure 流分析作业,其中一个事件中心作为输入,一个函数作为输出。对于数据流,我想要做的是每 X 秒输出最后 X 秒的数据,以便当调用输出中的函数时,它会传递最后 X 秒的数据。有没有办法通过流分析来实现这一点,或者有更好的工具来实现这一点。我看到有一个 LAG 函数,但我看不出它如何用于此目的。

I have an Azure Streaming Analytics job that has an event hub as an input and a function as an output. With the stream of data, what I'm looking to do is to output the last X seconds of data every X seconds so that when the function in the output gets called, it is passed the last X seconds of data. Is there a way to achieve this with Streaming Analytics, or is there a better tool for this. I see there is a LAG function but I can't see how it can be used for this.

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文