azure - 在流分析中关联事件

Question

我有许多基于设备值的事件。它们以间隔读取，例如每小时读取一次。这些事件被传递到事件中心，该中心用作流分析 (SA) 作业的输入。

我想汇总并计算 SA 中的平均值。目前，我使用源 ID 和其他属性对 SA 中的事件进行聚合和分组，以创建正确的组和平均值。问题是平均值不正确。我认为这些事件要么不完整和/或不相关正确。

使用 TumblingWindow 会根据时间生成多个静态窗口，但我需要聚合的事件可能会遇到两个或更多窗口。

据我了解，使用 SlidingWindow 将在特定条件下触发输出，并在指定时间间隔内“回顾”。这个对吗？如果正确，我可以将相同的 ID（如 JobId）附加到我需要聚合的每个事件以及指示它是否是最后一个事件的值。当最后一个事件进入 SA 时，SlidingWindow 被触发，我们可以“回溯”所有具有相同 id 的事件。这可能吗？ 

在这种情况下还有其他选择吗？基本上，我需要根据时间以外的其他特征关联许多事件。

我希望你能帮助我。

标签： azureazure-stream-analytics