问题标签 [stream-analytics]

我有一个流分析作业，它从 IOT 集线器接收输入并将数据写入 Azure SQL 数据库。我目前的查询如下

从 [输入] 中选择 [Column1,Column2...] INTO [Output]

是否可以只选择特定数量的行？我正在寻找类似以下的东西

从 [Input] 中选择 TOP 10 [Column1,Column2...] INTO [Output]

任何建议，将不胜感激。谢谢

我一直在使用 ffprobe 从视频流中读取数据包进行分析。然而，它的速度非常缓慢。阅读 30 分钟 720p 视频大约需要 8 分钟。我目前正在使用以下命令：

这为我提供了每个数据包的以下信息：

我确实在文档中阅读了相当多的内容，但看起来就是这样，或者有没有办法让它更快？

或者是否有任何替代 CLI 工具可以更快地从视频中获取上述信息？

我只是在 2019 预览版中使用Visual Studio 的 Azure 流分析工具创建一个 Azure 流分析，但它说不支持 Visual Studio 的版本。我确信我已经安装了所需的工作负载和扩展。

我还确定我已使用服务器资源管理器连接到我的 Azure 订阅。

知道为什么吗？它真的不支持还是我错过了什么？

我们有一个物联网应用程序。应用程序必须检测设备电池电压的任何突然变化（异常）。我们计划使用 Azure 流分析中内置的异常函数来完成这项任务。

当我在流分析查询中运行异常函数时，如下所示

它返回以下错误消息：

发生了意外错误。请打开支持票以调查并提供以下客户请求 ID：_______

但是在删除异常函数后运行相同的查询时工作正常。

我在网络上的任何地方都找不到有关此问题的任何参考资料，因此我们将不胜感激并提前感谢您的帮助。

我想通过使用纬度/经度数据（通过 Azure IoTHub 发送）和目标纬度/经度或多边形数据（来自参考输入）来使用流分析地理空间功能。

我知道我们可以在查询中加入流和参考输入，但是是否有可能实现一个解决方案，我们没有任何数据可以在流和参考输入之间加入，并且仍然使用计算点之间的距离ST_DISTANCE？

样本参考输入数据：

上面的数据会有更多的点，所以在查询中手动输入点不是一个好的解决方案。

我希望输出包含比较的点及其距离。

我需要将下面的 C# 代码翻译成 Azure 流分析可以使用的东西。

我有一个类似于以下内容的 C# 应用程序：

ProcessEvents() 将 inputEvents 传递给其他辅助方法的位置

我需要使用流分析来实现整个代码。var 文件部分是通过使用 Collect() 收集一堆事件来实现的。每个批次都发送到充当ProcessEvents()的 UDF 。但是，ProcessEvents() 返回下一次迭代所需的其他事件。由于 UDF 是无状态的，因此下一批将无法使用上一批返回的事件。

如何在流分析中重写上面的 C# 代码？

我尝试了以下方法：

• 使用 UDA 存储返回的事件。失败，因为由于某种原因它无法存储 JSON 数组并不断修改它。
• 使用参考数据输入来存储返回的事件。失败，因为它们只能在使用 JOIN 的流分析中使用，而不能在 UDF 中使用。

流分析 T-SQL 查询：

流分析 UDF 代码（短版）：

我正在使用流分析的 T-SQL 对流输入和参考数据输入进行完全外部联接。

我已经尝试了以下查询，但我不断收到错误消息“当加入流和参考数据时，参考数据必须在右侧”。

我想做两者的完全外连接 - 如果参考数据永远不会在左侧，我该怎么做？

我的预期输出是这样的：

我有输入的流分析工作：

1) “InputStreamCSV” - 链接到事件中心并接收数据。InputStreamHistory
2) "InputStreamHistory" - 输入流链接 BlobStorage。输入流CSV

输出：
1) “AlertOUT” - 链接到表存储并将警报事件作为行插入表中

我想计算 2018 年所有交易的平均金额（一个数字 - 5,2）并将其与 2019 年即将推出的交易进行比较：
如果新交易金额大于平均金额 - 将该交易放入“AlertOUT”输出中。

我计算平均值为：

接收新交易为：

如何结合这两个查询来检查新交易金额是否大于去年的平均交易金额？

我将以下 Json 输入从 Eventhub 传递到流分析。

但这项工作未能说明错误。

尝试写入 1 个事件时遇到错误：无法从“System.String”类型的属性“meter_totalcycleenergy”转换为“System.Single”类型的“meter_totalcycleenergy”列。

错误图像 如何处理这种情况。

我认为 Json 空值不完全是 SQL 空值，那么在查询中检查空值的正确方法是什么？

Meter_totalcycleenergy 的数据类型在我的数据库中是浮动的。

我正在尝试计算来自连接到 azure IoT Hub 和流分析的数据记录器的信号 (DI_1) 的持续时间。

输入数据如下所示：

结果应如下所示：

有谁知道如何在天蓝色流分析中实现这一点？

目前，当数字输入发生变化时，ASA 输出是具有时间和数字输入（1 或 0）的数据集。

用以下代码实现：

在这里，我必须计算 PowerBI 中的时间差。现在我想直接在天蓝色流分析中计算它以避免在 PowerBI 中计算。

非常感谢您的帮助！