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

Question

用于Python的azure-eventhub (1.3.2)库仅允许用户发送和使用Azure EventHub的消息。

将事件中心客户端库用于Python：

• 通过发件人将事件发布到事件中心服务。

• 通过接收器从事件中心服务读取事件。

出于概念和调试的目的，我尝试使用Azure门户上可用的查询控制台，但体验是...效率低下（多次崩溃，重新加载等）。有没有一种方法可以从python代码执行蒸汽分析查询？

示例查询：

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

Answer 1

不幸的是，Azure Stream Analytics不支持来自python脚本的查询。

Azure流分析中的查询以类似SQL的查询语言表示。语言结构记录在Stream Analytics query language reference指南中。

查询设计可以表达简单的传递逻辑，以将事件数据从一个输入流移至输出数据存储，或者可以进行丰富的模式匹配和时间分析，以计算各种时间范围内的聚合，如构建IoT解决方案通过使用Stream Analytics指南。您可以合并来自多个输入的数据以合并流事件，还可以针对静态参考数据进行查找以丰富事件值。您也可以将数据写入多个输出。

有关更多详细信息，请参见“ Query examples for common Stream Analytics usage patterns”。

希望这会有所帮助。