问题标签 [stream-analytics]

我提供了一个 5 MB 大小的 JSON 文件作为 Azure 流分析的输入，我收到以下错误。

“选定的文件‘文件名’必须在 1 到 2097152 字节之间”

选择的流单元数为 3。如何使流分析读取大型 Json 文件作为输入？

我正在使用 UNION 函数在流分析中运行查询。我想获得查询结果的不同值。由于 UNION 允许在 Azure 流分析中重复，我得到的结果具有重复值。我也尝试过使用 DISTINCT 关键字，但即使它也不起作用。

以下是我尝试的查询。

在上面的查询中，ID 是唯一的，时间将是一个值数组，时间和值为 ABC/XYZ。

输入json文件如下。

没有重复的预期结果。

多个 LEFT JOINS 在 Azure 流分析中未按预期工作。

我在 Azure 流分析中使用左联接并获取前两个 JOIN 的值和其余 LEFT JOIN 的空值

以下是我使用的 Json 输入。

下面是我使用的查询。

实际结果如下。

相应时间的 PQR 和 IJK 的预期值。

我有 IoT 中心，它从许多设备收集消息。来自 IoT 中心的数据被发送到流分析，现在我想流分析，显示所有设备的列表以及最后一个请求。即，一个表，其中有例如10 个设备，每个设备都有它的最后一个请求。

我的实际代码：

在此查询中，我在 deviceId 上有错误：

我不知道如何解决不支持表达式的问题并更改所有设备的最后请求；/

我们正在尝试使用 IoT 中心、流分析和表存储处理仪表板上的事件驱动图标（开/关/活动）。我无法让实际过程在 6 秒内完成。流分析的水印是恒定的 5 秒。该网站声称即时处理。https://azure.microsoft.com/en-us/services/stream-analytics/

我已经通过一个非常简单的查询来设置流分析，将排队时间存储到表存储中。我确保事件排序时间和乱序消息都设置为 0 秒并丢弃。我通过新的流分析部署做到了这一点。还使用了 6 的最大允许 SU。我将批处理输出设置为 1。

我希望总处理时间低于 1.5 秒，水印低于 100 毫秒。

我想使用包含 CROSS APPLY GetArrayElements() 的流分析查询将此数组转换为行，但此函数需要数组名称。显然没有名字。有什么建议么？

要解析的 JSON 示例：

我尝试了下面的代码，但遇到了错误：

错误：列名无效：'arrayvalue'。具有该名称的列不存在。

我在 Azure 中创建了流分析作业，我想在 Power BI 中显示结果。这项工作非常简单，因为我要做的就是每 1 秒显示过去 10 分钟内发生的事件数。但是，当最后 10 分钟过去时，我需要重置计数器，这意味着我希望窗口在 10 分钟后重新启动。

我有以下选择：

• 使用持续时间为 10 分钟的翻转窗口：不，因为这不会每 1 秒显示一次结果，而是在 10 分钟后显示
• 使用 Hopping 窗口：HoppingWindow(Duration(minute, 10), Hop(second, 1))。这在前 10 分钟内有效，但在那之后就不行了，因为它会跳动 1 秒。
• 使用大小为 10 分钟的滑动窗口：否，因为当事件发生时它会滑动 10 分钟
• 使用 SessionWindow：否，因为会话窗口仅在窗口关闭时才返回输出。

我想不出一个解决方案，因为我的目标是一个窗口，它会扩展直到达到最长 10 分钟的持续时间（然后它会重新打开）并每隔一秒产生一次输出。欢迎任何帮助。

我在 Siddhi 中编写了一些代码，用于记录/打印一批最后 100 个事件的平均值。所以事件 0-100、101-200 等的平均值。我现在想将这些平均值相互比较以找到某种趋势。首先，我只想看看对于一定数量的平均值是否存在一些简单的下降趋势。例如，我想将所有平均值与所有即将到来的 1-10 平均值进行比较。

我查看了 Siddhi 文档，但没有找到我想要的答案。我尝试了一些分区解决方案，但这不起作用。下面的代码是我现在所拥有的。

我在下面定义了输入流。Datetime 字符串是 like 2010-09-01 06:59:00.000，结果是 double like 157,382，而 UnixDateTime 的类型是 long like 1283324340111。

我想为显示result列平均值的 100 个事件制作长度批次，并且我想将这些批次相互比较。我想对接下来的 5 个批次（每个批次都包含 100 个事件）进行滑动比较。所以我想比较第一批（0-100 事件）和第二批（101-200），直到第六批（501-600）。我希望第二批比较到第七批。我想通过比较实现的是，当 4 个或更多（来自 5 个）批次的批次平均结果全部大于或全部小于 1（与原始批次的平均结果相比）时，我想记录有关原始批次的信息。

我的代码如下。问题我不知道确切的语法。我查看了 WSO2 和 Siddhi 的教程和文档，但我无法解决问题。

我需要根据文档中可用的另一个字段的值来设置一个字段的值。

以下是我尝试获取要求的 SAQL。

如果 DESC 是abc那么NUMID应该是001并且如果 DESC 是pqr那么NUMID应该是002。

除了单独编写最后两个选择语句之外，还有什么选项可以在单个 SELECT 查询中编写它，如下所示？