问题标签 [stream-analytics]

我有存储在 Blob 存储中的 JSON 形式的输入我有 SQL Azure 表形式的输出。

我编写的查询并成功地将 JSON 中特定属性的值移动到 SQL Azure 表的相应列。

现在对于一列，我想将整个 JSON 有效负载作为序列化字符串复制到一个 sql 列中，我没有得到适当的库函数来执行此操作。

这个CustomDimensionsPayload实际上应该是一个 JSON

我对流分析查询 UNION 操作结果有疑问。

以下查询如果第一部分没有返回行，第二部分有 5 行返回，UNION 假设返回 5 行作为结果，但它什么也不返回。

SELECT EventKey, Events.ACP.EventType, Event.ACP.Details, NULL Involved FROM Input1
WHERE Events.ACP IS NOT NULL

联盟

从 Input1 中选择 EventKey、Events.MED.EventType、Event.MED.Details、Event.MED.Involved，其中 Events.MED
不为空

运行每个查询都会有正确数量的结果，但联合操作后什么也不返回。

问候

我尝试在 Azure 流分析中使用来自 Microsoft Azure 机器学习工作室的训练模型。在开始使用我的 IoT-Stream 传感器数据之前，我尝试了以下示例： https ://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-machine-learning-integration-tutorial

我可以部署 Web 服务，它可以与控制台应用程序一起正常工作。网络服务的结果：

教程中流分析中的 T-SQL 如下所示：

不幸的是，它不起作用。有人可以解释result.[Scored Labels]

是否可以调试我的流分析作业？我没有输出。没有结果文件，没有警告，没有例外......

所以我有时间戳，我需要将其转换为时间。所以我试过这个

从 Bigint 转换为日期时间值

但它在 Azure Function App 中不起作用：/

基本上我有这个代码

编辑 1

我收到以下错误：不支持表达式：'convert ( bigint , XEvent . [Timestamp] )'。

编辑 2

我也试过这样：

但它返回未知错误

（https://msdn.microsoft.com/en-us/library/azure/dn834997.aspx）

我在使用流分析窗口时遇到了一些问题。我的流分析作业的输入是一个事件流，其中包含来自属于信号的传感器/实体的温度读数。每个信号有大约 600 个实体。示例事件如下所示。

流分析正在从看起来像这样的参考数据 blob 中读取每个实体的阈值。

如果温度值大于它们各自的阈值，我编写了一个流分析查询来过滤事件并在 Azure SQL 数据库中插入一个“警报”。

我现在需要的是在上面放一个滑动窗口（我假设）。如果实体的温度值连续超过其各自的阈值 1 小时，我只想创建一个“警报”。插入的行应该包含与窗口中最后一个事件相关的数据。

我是流分析和 T-SQL 的新手，老实说，我并不完全了解窗口函数的工作原理。这是我的问题...

1. 如果我连续 30 分钟收到不良事件（温度大于阈值），然后收到一个好事件，是否可以编写一个查询，以便从下一个坏事件开始一个新窗口？

2. 是否可以为窗口中的最后一个事件选择数据？我尝试使用 LAST() 和 LAG() 但它给了我一个编译错误，说“不能在没有聚合函数的情况下使用 GROUP BY”。问题是我不需要聚合函数，只需要最后一个事件值。

我已经被这个问题困扰了好几天，任何帮助将不胜感激。

另外，这是我的第一个问题，所以请原谅我的笨拙

我的流分析查询存在语法问题。以下是我的流分析查询，我试图从事件中获取以下字段：

• 车辆编号
• 先前和当前燃料水平的差异（对于每辆车），
• 当前和先前里程表值的差异（对于每辆车）。

非工作查询

以下是在一系列事件上运行上述查询/作业的一个示例输入事件：

运行流分析作业时会引发以下语法错误：

无效的列名：“有效负载”。具有该名称的列不存在。

具有讽刺意味的是，以下查询工作得很好：

工作查询

WORKING QUERY 和 NON-WORKING QUERY 之间的唯一区别是使用的 LAG 结构的数量。NON-WORKING QUERY 有两个 LAG 结构，而 WORKING QUERY 只有一个 LAG 结构。

我提到了流分析查询语言，他们只有基本的例子。还尝试查看多个博客。另外，我也尝试过使用GetRecordPropertyValue () 函数，但没有运气。请建议。

先感谢您！

我遵循了一个IOT Hub 教程并让它工作。然后我创建了一个流分析作业并将上面的内容用作输入（在测试连接时有效）。

但是我没有看到收到任何输入。运行示例测试时，出现以下错误：

说明 错误代码：ServiceUnavailable 错误消息：目前无法连接到输入源。请检查输入源是否可用以及是否未达到连接限制。

我可以看到 IOT Hub 中收到了遥测消息。任何帮助，将不胜感激

在创建输出到 Blob 存储的 Stream Job 时，必须指定“路径模式”，例如：

这似乎是 UTC，即使仅指定 {date}，时区也是相关的。

它使用的是什么时间，是否可以参考时区？它是否使用 TIMESTAMP，如果是，我可以用时区修改它吗？

编辑：2017 年 2 月 27 日 - 这是我正在使用的典型查询：

谢谢

-约翰

我正在尝试将传入的 JSON 对象格式化为 JSON 对象到输出中

输入：

我想过滤这个对象（删除一些无用的属性）并有这样的东西。

输出：

有人可以帮助我查询或指出正确的方向。谢谢

我正在使用流分析查询来过滤我输入的复杂 Json 对象。

输入：

这是我的查询：

我得到这样的东西：

我想将此 JSON 数组包装到具有唯一“id”的 JSON 对象中，以获得如下内容：

我找不到办法做到这一点。我尝试创建调用用户定义函数的第三个选择：

但这适用于数组中的每个对象..所以我得到了这个：

有没有办法用查询包装该数组中的所有嵌套对象？