问题标签 [azure-stream-analytics]

我拆分了我的输入数据，两个选择具有不同的 where 子句，然后我想在一些聚合后将它们重新连接在一起，并使用左外连接。

这工作正常，左表中的连接数据按预期具有空值。如果我可以做一个 IsNull(lefttable.column,0) 就可以了，但据我所知，不支持 IsNull，有没有其他方法来构建我的语句？

我正在将数据从流分析发送到 powerbi。大多数时候它工作正常，但我不时上传大量数据用于测试目的。我注意到我的 SU 利用率为 100%，并在流分析中收到错误消息，说我可能会因此遇到奇怪的行为。在大多数情况下，当我转到 powerbi 时，我会看到我的数据集，但当我尝试探索它们时，我什么也得不到。表格页面未打开。

我试图用流分析作业中的最后 10 秒平均值替换空值。这需要在流和我在 With 子句中计算的平均值之间进行自连接。它给了我重复（我得到相同的记录两次或三次）？关于什么是错的或如何正确地做的任何建议？我的查询是：

azure stream如何实时返回处理后的数据？我看到大多数示例将处理后的数据推回数据库或仪表板。我需要为单个请求实时发生所有事情（第 4 步）。您如何以最小的延迟实现这一目标？下面的例子：

1) 客户端请求的页面 2) 页面将一些数据发送到 azure 流 3) Azure Stream 使用来自 5 秒窗口的数据和数据进行逻辑和计算 4) 将结果发送回页面，以便它可以执行一些即时操作 5) 将结果存储在报告数据库

我正在向 PowerBI.com 输出流分析作业。它成功地发送了前 11-100 条消息，但之后它失败了。在操作日志中，它表示操作“未能发送事件”，并被归类为“PowerBIOutputAdapterTransientError”，没有太多其他信息。此类错误的症状是什么？

消息仍在通过事件中心，但所有操作似乎都在 PowerBI 端进行。

我正在使用 Azure 流分析，我的输入是 Eventhub，事件序列化格式是 CSV，DELIMITER 是逗号（，）。我的查询是从输入中选择 DeviceId，温度，我的输出是 sql 数据库。但是当我的工作正在运行时，它给了我类似的错误

“反序列化后，发现 0 行。如果这不是预期的，可能的原因可能是缺少标题或格式错误的 CSV 输入”

第二个错误是

无法将输入事件反序列化为 Csv。一些可能的原因：

1) 畸形事件

2）输入源配置错误的序列化格式..

我正在像这样在 Eventhub 上发送数据

I just extended the 'select' part of my Stream Analytics query, and suddenly get: "Query compilation error: Too many aggregate expressions."

Searching for this error yields no results, except an old, google-cached page about 'Azure Stream Analytics Preview limitations' where it is said that "The maximum number of supported aggregate functions in a Stream Analytics job query definition is 7."

But that was for the Preview of course.

=> Is it normal to get this error with the current (GA) version of Stream Analytics? What is the limit?

thanks!

我正在寻找一种优雅的方式来发送电子邮件通知，以防流分析作业检测到已通过阈值 - 与 Santosh Balasubramanian 在 Channel 9 上显示的大致相同。

通过阈值后，一条记录将写入 SQL 表。这应该会触发要发送的电子邮件。

一秒钟，我想我可以在该表上定义一个移动服务“插入”脚本，如此处所述，但当然，流分析作业不会通过移动服务 API...

到目前为止，我能想到的最佳选择是改用Mobile Services Scheduled Job，它每 5 分钟左右轮询一次表，如果发现新记录，则发送电子邮件。

有没有更好的办法？还是应该为流分析添加功能请求以启用移动服务作为输出类型？

我有一个直接来自事件中心并进入表存储的 Azure 流分析查询。查询是：

输入正文具有 Id Guid 和 CreatedAt 日期时间。这些分别用作表格输出的分区键和行键。

虽然，列 Id 和 CreatedAt 也出现在表中。如何将这些列用作分区键和行键，但不让它们出现在输出表的列中？

我有一个使用事件中心接收数据的项目，每秒发送一次，数据由使用 SignalR 的网站接收，一切正常，我一直通过流分析作业将数据存储到 blob 存储中，但这真的很慢，而且我只收到 6 台设备的数据量，随着数据的增加，它会变得更慢，我需要访问数据以通过网站上的图表显示历史数据，并且然后用进来的实时数据来补充。

我真的不需要每秒存储一次数据，所以考虑只每 30 秒存储一次，但是到 SQL DB 中，我想要做的仍然是每秒接收数据，但每 30 秒存储一次，我尝试了一个翻滚窗口，但据我所知，这只是每 30 秒转储一次所有内容，而不是单个条目。

我是否想念翻滚、滑动和跳跃窗口，我猜我不能以这种方式使用它们？如果是这种情况，我猜唯一的方法就是将输出数据库作为输入，这样我就可以将时间戳与当前时间交叉引用？

除非有人有其他想法？任何帮助，将不胜感激。

谢谢