问题标签 [azure-stream-analytics]

我正在尝试创建一个流分析作业。消息以以下格式发送JSON：

当我运行我的工作时，我收到以下错误：

我的输入有一个只有两个值的“条件”字段。让我们只假设值“A”或“B”。

当在翻滚窗口内找到至少一个条件=A的事件时，应该只输出条件=A的事件。但是，当没有找到 A 的事件时，应在同一窗口中仅输出 B 的事件。给定以下输入，滚动窗口为 4 个刻度：

输出应如下所示：

如何设置我的步骤，以便从我的输入中获得以下输出？我尝试了几个使用 group 的选项，但没有成功

我想存储正在登录 App Ins 的所有自定义指标，移动到 SQL 数据库。

我已经在 App Ins 上启用了 cont 导出，它将 App Ins 自定义指标转储到 blob 中。

从这里想要一个我想要 Stream Analytic 转储 SQL Azure 中的数据。

问题是我无法在 SA 中编写转换查询。

我们将记录 100 个自定义指标。

我想像这样将它们存储在SQL中

我正在尝试通过查询来实现这一点：

但没有运气，请建议。

谢谢

案例：我们有一个将数据发送到 eventhub 的代理，我们使用事件中心作为使用 ASA 进行聚合和计算的输入。当代理有问题时，它会向eventthub发送一个值（可能是serval days发送一个错误值），我们想在收到代理错误值时向输出写入一个值，那么如何解决这个问题呢？我们不能使用窗口，因为它是数据触发的。

案例：我们有一个 1 天的聚合窗口，它将从事件中心接收到的总值相加（1、2、3……每分钟发送一个值），我们将输出设置为一个名为 1dayresult 的 blob。现在我们要获取 blob 数据作为另一个 1week 聚合输入，每周我们都想从 blob 中获取数据并进行计算，那么我们可以将 1day 结果 blob 设置为 1week 聚合的输入吗？我们知道可以将窗口单位设置为 7day，但我们认为这会降低性能，因为如果我们将 1day 结果 blob 作为输入，我们只需要 7 个值，但如果我们使用 7day 窗口，我们会得到超过 7*24*60 的值，然后进行计算。我们也希望有一个月的聚合，但是窗口的最大大小是 7 天。那么如何实现呢？

我需要一种可以将 2 SA 输入的输入组合到 1 SA 输出的方法。

例如

我正在尝试从两个输入中读取数据并希望将它们放在一个输出中（SQL 表）得到一个异常说“不允许重复的输出名称”</p>

我正在从设备流式传输数据，并且我想使用 LAG 函数来识别从特定设备接收到的最后一个值。数据不会定期流式传输，在极少数情况下，从设备接收数据之间可能需要几天的时间。

LIMIT DURATION 条款是否有最长期限？

LIMIT DURATION 周期长有什么缺点吗？

我正在尝试构建一个将数据插入 Sql 数据库的逻辑应用程序。数据来自流分析作业，在服务总线主题上输出，在服务总线触发器中的逻辑应用程序中使用。

要填充插入行的属性（假设它只有一列“名称”），我发现这应该使用以下语法：

如果消息正文包含“名称”属性。

但是，运行此程序时我收到以下错误消息：

'，第 0 行，第 0 位置。'。有关使用详情，请参阅https://aka.ms/logicexpressions#json。'。"}

因此，内容似乎包含在另一个阻止 json 解析工作的信封中。

1）任何简单的方法如何解决这个问题？

2) 微软堆栈中的这种集成难道不应该在没有这种嘲笑的情况下工作吗？

谢谢，斯特凡

我有一个场景，我将两个事件数据发送到具有不同分区键/分区 ID 的事件中心。

现在在我的流分析中，我创建了两个具有相同连接字符串的输入别名（比如 machine1input 和 machine2input ）和两个不同的输出别名，但这里每个输出别名都指向单独的表存储。

现在我的事件数据是这样的。

在这里，我将 MachineName-M1 发送到单独的分区，例如 1，将 MachineName-M2 发送到单独的分区，例如 2。

现在我有两个 azure storage tableMachine1Record和Machine2Record. 现在我想在流分析查询窗口中编写查询，这样机器 M1 记录应该存储在Machine1Record表中，机器 M2 记录应该Machine2Record作为数据自动存储在表中。

我已经尝试了很多查询来实现这一点。

但他们都没有工作。请在这方面提供帮助。谢谢。

我们在使用 Azure IotHub 时遇到了一些问题。我有一个流分析工作，正在听一个 IotHub。我的流分析工作运行得非常好，刚刚开始显示没有输入和输出。重新启动时出现以下错误“流分析作业存在验证错误：查询 EventHub 返回错误：ProtocolName。” 哪一种向我表明它不能再听 IotHub 了。有没有其他人有类似的问题？帮助解决这个问题会很棒。

流分析作业错误