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

Question

python的azure-eventhub (1.3.2)库只允许用户从azureeventhub发送和使用消息。你知道吗

Use the Event Hubs client library for Python to:

• Publish events to the Event Hubs service through a sender.

• Read events from the Event Hubs service through a receiver.

出于构思和调试的目的，我尝试使用Azure门户上可用的查询控制台，但体验是。。。无效（多次崩溃、重新加载等）。有没有一种方法可以从python代码执行流式分析查询？你知道吗

查询示例：

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

Answer 1

没有用于azure流分析的python sdk。你知道吗

如果必须使用python，可以尝试使用python调用related powershell script。你知道吗

Here是如何使用python调用powershell的示例。你知道吗

Answer 2

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

Azure Stream Analytics中的查询是用类似SQL的查询语言表示的。语言构造在Stream Analytics query language reference指南中有文档记录。你知道吗

查询设计可以表达简单的传递逻辑，将事件数据从一个输入流移动到一个输出数据存储，也可以进行丰富的模式匹配和时间分析，以计算不同时间窗口的聚合，如使用流分析指南构建物联网解决方案中所述。您可以连接来自多个输入的数据以组合流式处理事件，还可以对静态引用数据进行查找以丰富事件值。也可以将数据写入多个输出。你知道吗

有关详细信息，请参阅“Query examples for common Stream Analytics usage patterns”。你知道吗

希望这有帮助。你知道吗