从python脚本执行Azure蒸分析查询

Question

python的azure-eventhub (1.3.2)库只允许用户发送和使用来自Azure EventHub的消息。

使用Python的事件集线器客户端库可以：

• 通过发件人将事件发布到事件中心服务。
• 通过接收器从事件集线器服务读取事件。

出于概念和调试的目的，我尝试使用Azure门户上可用的查询控制台，但经验是.非生产性的(多次崩溃、重装等)。有没有办法从python代码执行热气腾腾的分析查询？

示例查询：

SELECT
    [event],
    DATEDIFF(...)
INTO
    [Output]
FROM
    [input] TIMESTAMP BY Time

Answer 1

没有用于天蓝色流分析的python。

如果您必须使用python，您可以尝试使用python调用相关powershell脚本。

这里是如何使用python调用powershell的一个示例。

Answer 2

不幸的是，Analytics不支持python脚本中的查询。

中的查询用类似SQL的查询语言表示。语言结构在流分析查询语言引用指南中有文档说明。

查询设计可以表示简单的传递逻辑，将事件数据从一个输入流移动到一个输出数据存储区，或者进行丰富的模式匹配和时态分析，在不同的时间窗口上使用stream指南计算聚合，比如在构建一个IoT解决方案中。您可以将来自多个输入的数据连接起来，以组合流事件，还可以对静态引用数据进行查找，以丰富事件值。您还可以将数据写入多个输出。

有关详细信息，请参阅"常见流分析使用模式的查询示例“。

希望这能有所帮助。