Выполнять аналитические запросы Azure для парения из скрипта Python

Question

Библиотека azure-eventhub (1.3.2) для python позволяет пользователям отправлять и получать сообщения только из Azure EventHub.

Использование клиентской библиотеки концентраторов событий для Python для:

• Публикация событий в службе концентраторов событий через отправителя.

• Чтение событий из службы концентраторов событий через получателя.

В целях разработки и отладки я попытался использовать консоль запросов, доступную на портале Azure, но опытбыл ... непродуктивным (множественные сбои, перезагрузки и т. д.).Есть ли способ выполнить паровые аналитические запросы из кода Python?

Пример запроса:

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

Answer 1

Python sdk для аналитики потоков Azure отсутствует.

Если вам нужно использовать python, вы можете попробовать использовать python call связанный сценарий powershell для ваших целей.

Здесь - пример того, как использовать PowerShell для вызова Python.

Answer 2

К сожалению, Azure Stream Analytics не поддерживает запросы из сценария Python.

Запросы в Azure Stream Analytics выражаются в языке запросов, подобном SQL.Языковые конструкции описаны в справочнике по языку запросов Stream Analytics .

Конструкция запроса может выражать простую сквозную логику для перемещения данных событий из одного входного потока в хранилище выходных данных,или он может выполнять богатое сопоставление с образцом и временной анализ для расчета агрегатов по различным временным окнам, как в Построить решение IoT с помощью руководства Stream Analytics.Вы можете объединять данные из нескольких входов для объединения потоковых событий и выполнять поиск по статическим справочным данным для обогащения значений событий.Вы также можете записывать данные на несколько выходов.

Подробнее см. " Примеры запросов для общих шаблонов использования Stream Analytics ".

Надеюсь, это поможет.