问题标签 [stream-analytics]

我是 Steam 分析的新手，我需要帮助来完成特定任务。我有来自这种格式的 iot 集线器的遥测数据。基本上，我将获取机器遥测数据和该机器上的操作阶段流式传输到物联网集线器。阶段将用标签 ex:"stageid":"stage1" 表示。我需要使用基于时间戳和阶段标签的流分析来计算每个阶段所花费的时间。

数据包示例：

}]

}]

请帮助我，我们可以通过查询来实现这一点吗？查询可能是什么，或者其他最好的方法是什么？谢谢，

我有如下所示的有效载荷。我需要每 1 分钟获取第一个不同的批次值。请让我知道如何使用 isfirst 和 lag 或 last 在流分析中实现这一点

输出如：

BATCH=01,"2015-01-01T00:00:01.0000000Z" BATCH=02,"2015-01-01T00:00:03.0000000Z" BATCH=03,"2015-01-01T00:00:06.0000000Z" BATCH= 01,"2015-01-01T00:00:14.0000000Z" BATCH=02,"2015-01-01T00:00:18.0000000Z" BATCH=03,"2015-01-01T00:00:22.0000000Z" BATCH=01, “2015-01-01T00:00:27.0000000Z”批次=01，“2015-01-01T00:00:31.0000000Z”

我有一个 Azure 流分析 (ASA) 作业，它处理来自事件中心的设备遥测数据。流应该与来自 sql 表的参考数据连接，以使用额外的设备元数据增强每条消息。合并的条目应存储在 CosmosDb 中。

为设备元数据提供服务的 sql 数据库：

在 ASA 中，我使用一个简单的查询配置了参考数据输入：

我有执行连接的主要 ASA 查询：

这一切正常，合并的数据存储在 CosmosDb 中。但是，来自 sql 的 Metadata 列的值被视为字符串，并使用引号和转义字符存储在 comos 中。例子：

有没有办法将元数据中的 json 存储为适当的 Json 对象，即

我已经设置了一些传感器，我通过 Event Hub 接收数据 (JSON) 到 Stream Analytics 作业，再到 Data Lake Gen2。我只需要数据中的一些值并想添加一些值，例如楼层、房间，因为这些数据不包含在我从传感器接收到的数据中。由于它没有那么多传感器，我想我可以在流分析中手动添加它。例如，当序列号等于“1234567”时添加楼层“2”。在这里我遇到了一些麻烦，因为数据存储在数组中，如下所示。

我的目标是将数组中的元素（数据点）分离为单独的事件，但仍将传感器的值保留为 SerialNo、DateTime，并将值添加为地板、房间等。我不知道这是否可以执行？

这是我收到流分析的数据示例。在此示例中，它只有两个数据点，但有多达九个数据点的情况。原因是传感器测量许多不同的东西（例如温度、湿度），并在 1 小时和 24 小时内将它们自己的聚合结果平均化。

所以我希望从显示的数据中得到的结果看起来像这样：

我已经尝试过 GetArrayElement、CROSS APPLY、GetRecordProperties 等函数，但没有任何运气。可能是因为我没有以正确的方式应用它们。

我愿意接受每一个正确的建议:)

提前致谢！

我通过几个不同的桥梁接收来自一些传感器的数据。我收到的数据包含很多重复项。具有相同的序列号、值、（几乎）相同的日期时间等，但来自不同的网桥。数据不包括某种唯一的 eventId，只是每个事件唯一的时间戳，即使是重复的。因此我无法过滤它们。

这是一个例子：

是否有某种方式过滤掉流分析中的重复项？如果有可能，数据最终也会进入 Power BI。但是，在 Power Bi 中使用“删除重复项”时，您需要一种不同于其他所有内容的 EventId，但对于重复数据也是如此。

提前致谢！

如果我在查询中使用参考数据，我的 Azure 流分析作业不会检测到任何输入事件。当我只使用流数据时，它运行良好。这是我的查询：

我使用 eventthub 和 blob 作为输入，结果是一样的 - 仅在没有参考数据的情况下工作

Inb4

• 当我使用示例参考数据测试查询时（我正在上传与参考数据位置中存储的完全相同的文件），它返回预期值
• 我已经测试了两个输入并且测试成功进行了
• 数据来自逻辑应用程序，该应用程序将其从保管箱复制到在 Azure 流分析中用作输入的 eventthub 或存储帐户（我已经测试了这两种方案）。即使看到这个运行成功，ASA 中仍然没有出现输入事件。

这个想法是让车站的坐标离我的定位更近 300 m。

我需要在 Azure 流分析中找到在 5 分钟翻滚窗口中至少出现 3 分钟的客户端。

下面的代码可以找到 5 分钟窗口中出现的人数。

但是，我想计算在此列表中至少存在 3 分钟的人。使用他们的第一次出现和最后一次出现（基于他们的查询时间）。

问题是我不知道流分析中的代码样式

我正在尝试使用以下查询对 Azure 流分析中具有特定值的结果进行计数：

问题是当资产提交 {0, 1, 0, 1, 0} 时，我得到的不是 2（即提交的 1 的计数）的计数，而是 5，即进来。此外，它将在第二个语句中将 HISTORY.ConditionResult 中的所有值设置为 1，即使它们在 WITH 语句中为 0。

这是 HISTORY 语句中 LAG 函数的结果吗？如果是，我将如何获得真值的计数？

我在计算每个区域的用户时遇到问题，每个用户都会将他们的语言环境发送到服务器。有人可以帮助我实现这一目标，谢谢。输出流分析应该是这样的：

输入数据：

每次我必须更新 Stream-Analytics 服务的查询时，我必须先停止它，更新查询，然后重新启动它。所有这些都是从 Azure 门户手动完成的。

这是我探索和理解流分析的初始阶段，但现在我必须将其提升到一个新的水平，为此，我需要在运行时不断更新查询，我不想手动进行。

有什么可能的解决方案吗？