【发布时间】:2016-10-14 06:40:09
【问题描述】:
我的流分析工作有问题。我正在从 IoT 中心提取事件,并根据它们的自定义时间戳将它们分组到时间窗口中;我已经编写了一个正确执行此操作的查询。但问题是它只是没有将任何内容写入我的输出表(作为我的存储帐户上的 NoSQL 表)。
查询在查询编辑器中运行没有问题(使用示例输入文件进行测试时)并产生正确的输出,但在“真实”运行时,它不输出任何内容(输出表保持为空)。我什至尝试重命名表并输出到 blob 存储,但没有骰子。这是查询:
SELECT
'general' AS partitionKey,
MIN(ID_frame) AS rowKey,
DATEADD(second, 1, DATEADD(hour, -3, System.TimeStamp)) AS window_start,
System.TimeStamp AS window_end,
COUNT(ID_frame) AS device_count
INTO
[IoT-Hub-output-table]
FROM
[IoT-Hub-input] TIMESTAMP BY custom_timestamp
GROUP BY TumblingWindow(Duration(hour, 3), Offset(second, -1))
有趣的是,如果我在查询中省略任何窗口,那么表输出就可以正常工作。 几天来我一直在为此苦苦挣扎,所以我想我已经尝试了大部分显而易见的事情。
【问题讨论】:
标签: azure azure-stream-analytics