stream-analytics

1热度

1回答

Stream Analytics中的语法问题在Azure中运行的查询：列名无效：'payload'

我的流分析查询有语法问题。以下是我的分析数据的查询，在这里我想从该事件得到以下字段：车辆ID 以前和当前燃料水平（每车辆）的差异， DIFF电流和以前的里程表值（每个车辆）。非工作QUERY SELECT input.vehicleId, FUEL_DIFF = LAG(input.Payload.FuelLevel) OVER (PARTITION BY vehicleId LIMIT

0热度

1回答

Azure流分析窗口

我在流分析窗口方面遇到了一些麻烦。我的流分析作业的输入是一个事件流，其中包含来自属于信号的传感器/实体的温度读数。每个信号都有大约600个实体。示例事件看起来像这样。 { "SignalId": "1", "EntityId": "1", "Temperature": 78 } 流分析正在从参考数据blob中读取每个实体的阈值，该参数数据blob看起来像这样。

0热度

1回答

从记录到顶级提升已知属性导致流分析查询

我有一系列正在由流分析作业处理的动态数据。有几个可以明确查询的统一属性，但在查询时大部分有效负载是未知类型。我的目标是获取这个未知数据（记录）并将所有属性提升为写入Azure Table的结果查询中的顶级字段。我能够扁平化记录的属性，它总是作为子对象添加到查询中。 GetRecordProperties()没有帮助，因为我不想为每个属性返回一个单独的记录。我的查询看起来是这样的： WITH

0热度

1回答

Stream Analytics GetArrayElements as String

我有一个Stream分析作业，它从外部来源获取数据（我对数据格式化方式没有发言权）。我试图将数据导入到我的数据湖中，并将其存储为JSON。这工作正常，但我也想获得在CSV输出，这是我有麻烦。由于输入数据有一个数组作为列之一，所以当以JSON导入时它会识别它并提供正确的数据，即将它们放在括号[A，B，C]中，但是当我在CSV中使用它时获得表示为“Array”一词的列。我想我会将它转换为XML，使用

0热度

1回答

准备归档数据以进行流分析导入

在我有时间获取流程设置的提取策略&之前，我开始收集最终将通过流分析作业的数据。现在我坐在一个Azure blob存储容器中，其中有超过500,000个blob（没有文件夹组织），另一个容器有300,000个，另外一个容器的容量为10,000 - 90,000。生产收集过程现在将这些斑点写入YYYY-MM-DD/HH格式的不同容器，但这只是前进的很棒。我拥有的这些归档数据对于进入我的系统至关重要，

1热度

1回答

天青流分析将多个输入分组到一个输出

我正在使用azure流分析，并且希望将同一时间的多个输入分组到一个输出。 current output 如何修改我的代码，它在第一行打印，例如： {"HO","KSPF","07","03","#300","46091240","2017-05-31T10:17:34:4430000Z"}

1热度

1回答

在Stream Analytics blob输出中指定时区？

在创建流工作，其输出到Blob存储，人们必须指定一个“路径模式”，如： telemetry/{date}/{time} 这似乎是在UTC，甚至仅指定一个{日期}时，时区是相关的。这是什么时候使用的，是否可以引用时区？它是否使用TIMESTAMP，如果是的话，我可以用时区修改它吗？编辑：2017年2月27日 - 这里是我的工作典型查询： SELECT measurement.Ar

0热度

1回答

与流分析查询创建JSON对象

我试图进入的JSON对象作为JSON对象格式化成输出输入： { "id" : "001", "firstArray":[ { "tid" : 9, "secondArray":[ { "keep1" : "value1", "keep2" : "value2", "remove1" : "

0热度

1回答

将JSON包装到输出流分析查询中

我正在使用流分析查询来过滤我输入的复杂Json对象。输入： { "id" : "001", "firstArray":[ { "tid" : 9, "secondArray":[ { "key1" : "value1", "key2" : "value2" }, {...}

6热度

2回答

流媒体分析作业没有收到物联网集线器的输入

我遵循IOT Hub tutorial并使其工作。然后，我创建了一个Stream Analytics作业，并将上述内容用作输入（在测试连接工作时）。但是我没有看到任何收到的输入。在运行样本测试时，出现以下错误： Description Error code: ServiceUnavailable Error message: Unable to connect to input source a