使用静态引用数据时，Azure 流分析作业不生成任何输出

Question

我编写了一个使用流输入并将其与静态 json 参考数据连接的查询。在“测试结果”选项卡中测试查询（上传相同的示例参考数据）时，我得到了正确的结果。但是，启动作业时没有生成输出。

我的查询：

流输入每秒产生随机结果，如：

而 json 参考文件是：

监控仪表板也没有输入事件或输出。

我已确认在查询中未使用与参考数据的连接时创建了输出 blob。我已将 json 参考数据上传到存储容器中，并提供了路径模式：在我的示例中为 ref/Atm.json。

感谢您的帮助。

Answer 1

我只是好奇并尝试重现，我使用的查询与您的查询非常相似。

SELECT sum(A.amount),B.area_code
INTO Gen2
FROMEHInput A
JOIN JSONref B ON A.ATMCode=B.atm_code
group by B.area_code,TumblingWindow(minute,1)

这是您的输出。（所有垃圾数据，但它确认查询有效）

{"总和":63580.0,"area_code":20}

{"总和":73060.0,"area_code":30}

{"总和":68220.0,"area_code":20}

在这一点上，我想做一些改变来检查我是否可以重现你没有输出的情况，我只是将静态文件更新为不存在的文件，ASA 从未抱怨过，但我从未得到结果任何一个。我认为您可能会遇到同样的情况（正如您提到的那样，如果没有连接，一切都可以正常工作）。就我而言，我的静态文件位置类似于

当我创建参考输入时，我将文件名传递为

我认为出于某种原因，它在这里变得一团糟。

您可以尝试的其他方法将 TW 增加到更大 window .

让我知道进展如何。

Answer 2

我设法解决了这个问题。您建议的错误是我为参考数据指定的路径模式。所以我创建了一个容器，例如“mycontainer”，我刚刚将 json 文件放入其中。对我有用的路径模式只是该容器内 json 文件的名称。没有 "/" ，在我的例子中只有 Atm.json。

现在，流作业会在我的 blob 存储中创建输出文件。

Azure Stream Analytics Job generates no output when using static reference data