问题标签 [azure-stream-analytics]

我正在使用 Azure 流分析将我的 Json 复制到 DocumentDB，并使用 upsert 用最新数据覆盖文档。这对我的基础数据非常有用，但我希望能够附加列表数据，因为不幸的是我一次只能发送一个列表项。

在下面的示例中，文档在 id 上匹配，并且所有项目都已更新，但我希望“myList”数组与每个文档（具有相同 id）中的“myList”数据一起保持增长。这可能吗？有没有其他方法可以使用流分析来更新文档中的这个列表？

如果可能的话，我宁愿避免使用翻滚窗口，但这是一个可行的选择吗？

样本文件：

期望的输出：

我目前的查询：

1. Azure 流分析只能接受 JSON 文件，这是真的吗？
2. 您能否将管道分隔或其他文件格式摄取/发送到 Event Hub 并从流分析中使用它们？

根据这个网站

https://azure.microsoft.com/en-us/documentation/articles/stream-analytics-define-inputs/

iot hub 有一个属性，可用于流分析以识别设备。但是当我想在滞后函数中使用它时，会出现编译错误：

LAG(brightness, 1, -1) OVER (PARTITION BY IoTHub.ConnectionDeviceId LIMIT DURATION(minute, 10)) as lastBrightness,

有任何想法吗？

将流式分析查询配置到事件中心时收到此错误消息。我正在尝试查询到达事件中心的实时数据，因此我删除了窗口分组。我怀疑这是导致此错误消息的原因，并且不允许使用查询。但是，无论如何可以从事件中心获取真正的实时数据，还是只是通过使用可以允许在一个时间窗口内发生多个事件的窗口系统来伪？

这是我的查询以供参考：

我能够将消息从我的应用程序发送到 eventhub。但是我无法在流分析中输入这些消息。

我想在流分析中计算连续重复值。例如，我有一个传感器，它每秒记录值 0 或 1。如果我有超过 30 个连续的 0，我想设置一个 1 分钟的滑动窗口并计数。我不能在组子句中计算 0，因为它们可能不是连续的。例如，如果我有：

我想获得：

甚至更好，我想在同一分钟内获得它（最大连续 1 为 7，最大连续 0 为 7）

在 SQL 中，我会做这样的事情：

使用流分析，您具有 LAG 功能，但我找不到计算连续数字的方法。

有任何想法吗？

我目前正在通过事件中心和 EventProcessorHost 进行斗争。到目前为止，我发现的所有指南都建议在 Azure 云服务辅助角色中运行 EventProcessor。由于这些部署和更新非常缓慢，我想知道是否有任何 Azure 服务可以让我在更敏捷的环境中运行 EventProcessor？

到目前为止，我的粗略架构看起来像这样

设备 > IoT 中心 > 流分析作业 > 事件中心 > [MyEventProcessor] > SignalR > 客户端...

或者也许还有另一种从 Steam Analytics 获取触发 SignalR 消息的方法？

任何建议都受到高度赞赏。

谢谢，菲利普

我的工作有疑问

输出到 Azure blob 存储。我的 CSV 输出将列标题显示为

某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某某

但是我需要，

SomeChar, SomeInt

这也是输入 csv 中的内容。

我什至尝试将其输出为 JSON 事件序列化格式，但它不保留字段名称的区分大小写。我想在整个应用程序中保持区分大小写。Azure 流分析中是否有办法强制执行此操作？

我目前正在研究物联网，在我当前的项目中，我实现了将温度值发送到 IoT 中心的逻辑（使用 Raspberry PI2 和 BMP280 传感器），在天蓝色部分，我创建了流分析作业以接收来自 IoT 的消息集线器并根据我的查询过滤这些值，例如温度值是否超过 30 度，并将这些过滤值发布到事件中心是流分析作业的输出之一。

我在流分析作业中编写的查询。

我已经在 azure 中创建了一个事件中心，并在我之前创建的事件中心仪表板中通过流分析作业监控这些过滤值。

但是我想将事件中心的值（通过流分析作业过滤的值）发送到 IoT 中心，我将使用 UWP 应用程序（C# 语言）以警报消息/通知的形式接收这些值。

请告诉我如何在上述情况下做到这一点。

问候，

普拉迪普

I have stream analytics in azure that sends data to power bi. The data is a complex JSON and I am trying to write a proper query for stream analytics to get the data I need.

I wrote some query, but it returns a record and I cannot figure out what fields are inside the record. In power bi if I drag the field, it just says Record. I assume this is probably a list of JSON records. Is there any way to see the record as JSON or raw text in Power BI (or anywhere else)? I want to see the output of stream analytics, so I could improve my query.