Azure流式分析输入/输出

Question

我实现了一个非常简单的流式分析查询：

SELECT
    Collect()
FROM
    Input TIMESTAMP BY ts
GROUP BY
    TumblingWindow(second, 3)

我使用python脚本在事件中心输入上生成：

^{pr2}$

我从队列中消费：

...
while True:
    msg = bus_service.receive_queue_message(Q_NAME, peek_lock=False)
    print msg.body
...

问题是，我在Azure门户中的任何一点上都看不到任何错误（输入和输出都经过测试，并且没有问题），但是我无法从正在运行的流程中获得任何输出！在

我在查询运行时共享诊断的图片：

有人能告诉我从哪里开始故障排除吗？在

太感谢你了！在

更新

好吧，我想我已经解决了这个问题。
首先，查询格式如下：

SELECT
  Collect()
INTO
  [output-alias]
FROM
  [input-alias] TIMESTAMP BY ts
GROUP BY
  TumblingWindow(second, 3)

我试图删除TIMESTAMP BY子句，一切都很顺利；所以，我想问题出在这个子句上。在

我粘贴了一个JSON序列化输入数据的示例：

{
  "ts": "1970-01-01 01:01:17",
  "value": "foo"
}

有人可能会说时间戳太旧（70年代），但我也尝试使用当前的时间戳，但我没有得到任何输出和任何输入错误。在

有人能想象出哪里出了问题吗？谢谢您！在

Answer 1

我发现我的问题是Basic query with TIMESTAMP by not producing output的重复。在

因此，解决方案是不能使用70年代的数据，因为流式分析会认为所有元组都晚了，并且会删除它们。在

我重新尝试生成时间元组，经过长时间的延迟，我可以看到输出。在

谢谢大家！在

Answer 2

你能检查来自Azure门户的服务总线队列以了解收到的消息数吗？在