Stream Analytics查询命中大小限制

Question

我是Azure Stream Analytics的新手。我有一个事件中心作为输入源，现在我正在尝试对此流执行一个简单的查询。查询示例如下：

SELECT
count(*)
INTO [output1]
FROM
[input1] TIMESTAMP BY Time
GROUP BY TumblingWindow(second, 10)

所以我想计算在特定时间范围内到达的事件。

执行此查询时，总是出现以下错误：

请求超出最大允许大小限制

由于我已经缩小了检查的时间范围，并且可以确定在此时间范围内的事件数量不是很大（最多100个）我不确定如何避免此错误。

您有提示吗？

谢谢！

Answer 1

请求超出最大允许大小限制

此错误（我认为应该是更明确的错误，表明您违反了azure stream analytic resource and object limits。

这不仅与数量有关，而且与大小有关。请检查源输入的大小，或尝试减小窗口大小并再次测试。

1。源查询的记录大小是否意味着一个事件只能具有64 KB，或者此参数是否意味着64 K事件？

这意味着一个事件的大小应小于64KB。

是否有可能使用Stream Analytics仅选择某些事件的子字段，或者是减小事件大小的唯一方法在发送到事件中心之前？

据我所知，ASA仅收集用于处理它的数据，因此大小完全取决于源端和您的查询sql。由于您需要使用COUNT，因此恐怕您需要在eventhub方面进行一些操作。请参考我的想法：

使用Event Hub Azure Function Trigger，当事件流入事件中心时，触发该函数并仅选择部分键值，然后将其保存到另一个事件中心命名空间中。（只是为了减小源事件的大小）无论如何，您只需要到COUNT记录，我认为它对您有用。