Соединитель Azure Data Explorer для Microsoft Power Automate

Важно!

Этот соединитель можно использовать в аналитике в режиме реального времени в Microsoft Fabric. Используйте инструкции в этой статье со следующими исключениями:

• При необходимости создайте базы данных с помощью инструкций из статьи Создание базы данных KQL.
• При необходимости создайте таблицы с помощью инструкций из статьи Создание пустой таблицы.
• Получите URI запроса или приема с помощью инструкций в разделе Копирование URI.
• Выполнение запросов в наборе запросов KQL.

Соединитель Azure Data Explorer для Power Automate (ранее Microsoft Flow) позволяет управлять потоками и планировать их, отправлять уведомления и оповещения в рамках запланированной или активированной задачи.

Можно сделать следующее:

• Отправлять уведомления и оповещения на основе результатов запроса, таких как превышение определенных пороговых значений.
• Регулярно (например, ежедневно или еженедельно) отправлять отчеты, содержащие таблицы и диаграммы.
• Планирование регулярных заданий с помощью команд управления в кластерах. Например, копировать данные из одной таблицы в другую с помощью команды .set-or-append.
• Выполнять экспорт и импорт данных между Azure Data Explorer и другими базами данных.

Дополнительные сведения см. в примерах использования соединителя Azure Data Explorer для Power Automate.

Примечание

Чтобы соединитель Power Automate получил доступ к защищенному сетью кластеру, необходимо добавить исходящие IP-адреса , связанные с регионом соединителя, в список разрешений брандмауэра. Дополнительные сведения см. в статье Управление общедоступным доступом к кластеру Azure Data Explorer.

Создание потока с помощью соединителя Azure Data Explorer

Чтобы использовать соединитель, необходимо сначала добавить триггер. Вы можете определить триггер на основе повторяющегося периода времени или как ответ на предыдущее действие потока.

1. Выполните вход в Power Automate.

2. Создайте поток или на домашней странице Power Automate выберите Мои потоки>+ Новый поток.

   

3. Выберите Запланированный облачный поток.

   

4. В окне Build a scheduled cloud flow (Создание запланированного облачный потока) введите необходимые сведения.

   

5. Выберите Создать>+ Новый шаг.

6. В поле поиска введите Kusto или Azure Data Explorer и выберите Azure Data Explorer.

   

7. Выберите действие из списка. Описание каждого действия и инструкции по настройке см. в разделе Действия потока.

   Важно!

   Для выполнения требуется допустимое подключение к Azure Data Explorer для потока. Сведения о создании подключения см. в статье Создание подключения azure Data Explorer в Power Automate.

   

Действия потока

При выборе соединителя Azure Data Explorer можно добавить в поток одно из следующих действий:

• Выполнение запроса KQL
• Выполнение запроса KQL и отрисовка диаграммы
• Выполнение асинхронной команды управления
• Выполните команду управления и отрисовка диаграммы
• Выполнение команды управления show

В этом разделе описываются возможности и параметры каждого действия, а также приведен пример, как добавить действие отправки электронного письма в любой поток.

Выполнение запроса KQL

Примечание

Если запрос начинается с точки, это команда управления. Выполните команду асинхронного управления.

Используйте это действие для запроса указанного кластера. Действия, которые добавляются после этого, выполняют итерации для каждой строки результатов запроса.

Если выполнение запроса занимает более 8 минут, он завершится ошибкой с исключением RequestTimeout. Чтобы избежать этой проблемы, оптимизируйте запрос или разделите его на более мелкие части. Дополнительные сведения см. в рекомендациях по запросам.

Пример

Следующий поток запускает запрос каждую минуту. Запрос проверяет количество записей в таблице и отправляет электронное письмо, только если это количество больше 0.

Выполнение запроса KQL и отрисовка диаграммы

Примечание

Если запрос начинается с точки, это команда управления. Используйте команду "Выполнить управление" и отрисовка диаграммы.

Это действие используется для визуализации результата запроса KQL в виде таблицы или диаграммы. Например, используйте этот поток для получения ежедневных отчетов по электронной почте.

Если выполнение запроса занимает более 8 минут, он завершится ошибкой с исключением RequestTimeout. Чтобы избежать этой проблемы, оптимизируйте запрос или разделите его на более мелкие части. Дополнительные сведения см. в рекомендациях по запросам.

Пример

В следующем потоке результаты запроса будут представлены в виде временной диаграммы.

Выполнение асинхронной команды управления

Используйте это действие для асинхронного выполнения команды управления , что означает, что она будет продолжать выполняться в фоновом режиме. Действие возвращает идентификатор, состояние и состояние. Чтобы проверка состояние и сведения об асинхронной команде, используйте команду .show operations с идентификатором, возвращенным этим действием.

Если выполнение команды асинхронного управления занимает более 60 минут, она завершится ошибкой с исключением RequestTimeout.

Пример

Следующий поток запускает асинхронную команду для копирования 10 записей из таблицы TransformedSysLogs в TargetTable. Обратите внимание, что в запросе требуется ключевое слово async.

Выполните команду управления и отрисовка диаграммы

Используйте это действие для выполнения команды управления и отображения результата в виде диаграммы. Параметры диаграммы включают таблицу HTML, круговую диаграмму, временную диаграмму и линейчатую диаграмму.

Если выполнение команды управления занимает более 8 минут, она завершится ошибкой с исключением RequestTimeout.

Выполнение команды управления show

Это действие выполняет команду show management и возвращает результат, который можно использовать в следующих соединителях.

Если выполнение команды управления занимает более 8 минут, она завершится ошибкой с исключением RequestTimeout.

Пример

В следующем потоке выполняется команда .show operation для поиска состояния асинхронной команды с помощью идентификатора операции, возвращаемого при выполнении асинхронной команды.

Отправка результатов запроса Kusto по электронной почте

Вы можете добавить в любой поток шаг, позволяющий отправлять отчеты на любой адрес электронной почты.

1. Выберите + Новый шаг, чтобы добавить в поток шаг.
2. В поле поиска введите Office 365 и выберите Office 365 Outlook.
3. Щелкните элемент Отправка электронной почты (V2) .
4. Введите адрес электронной почты, на который нужно отправить отчет.
5. Введите тему электронного сообщения.
6. Выберите Просмотр кода.
7. Поместите курсор в поле Текст и выберите Добавить динамическое содержимое.
8. Выберите BodyHtml.
9. Выберите Показать расширенные параметры.
10. В поле Attachments Name -1 (Имя вложения 1) выберите Имя вложения.
11. В поле Attachments Content (Содержимое вложений) выберите Содержимое вложения.
12. При необходимости добавьте дополнительные вложения.
13. Если нужно, задайте уровень важности.
14. Щелкните Сохранить.

Создание подключения к Azure Data Explorer

Чтобы выполнить поток, содержащий соединитель Azure Data Explorer, необходимо использовать допустимое подключение к Azure Data Explorer. Вы можете создать и проверить подлинность нового подключения в левой области Power Automate, выбрав Данные>Подключения, или в потоке, выбрав Добавить новое подключение в меню соединителя Azure Data Explorer.

Ниже показано, как создать подключение в потоке.

1. В окне Run KQL query (Выполнение запроса KQL) нажмите значок с тремя точками в правом верхнем углу соединителя Power Automate.

   

2. Выберите Добавить новое подключение. При первом подключении вам будет предложено войти в систему, чтобы подтвердить подлинность подключения.

   

Аутентификация

Вы можете пройти проверку подлинности с помощью учетных данных пользователя или с помощью Microsoft Entra приложения. Чтобы пройти проверку подлинности с помощью учетных данных, выберите Войти и введите свои учетные данные.

Чтобы пройти проверки подлинности с помощью субъекта-службы, выполните следующие действия:

1. Выберите Подключение с помощью субъекта-службы.

2. Заполните форму, указав следующую информацию.

   • Имя подключения: описательное и понятное имя для нового подключения. В этом примере мы использовали MyApplication.
   • Идентификатор клиента: идентификатор приложения.
   • Секрет клиента: ключ приложения.
   • Клиент: идентификатор каталога Microsoft Entra, в котором создано приложение.

   Примечание

   Убедитесь, что приложение является Microsoft Entra и имеет право выполнять запросы в кластере.

   

   Когда проверка подлинности завершится, убедитесь, что поток использует недавно добавленное подключение.

   

   После установки подключения поток выполняется с использованием учетных данных приложения.

Проверка потока

Чтобы проверить, работает ли поток, изучите журнал выполнения потока:

1. Перейдите на Power Automate домашнюю страницу.

2. В главном меню выберите Мои потоки.

   

3. В строке потока, который вы хотите исследовать, выберите значок дополнительных команд, а затем — Журнал выполнения.

   

   В списке отображаются все выполнения потока, а также сведения об их времени начала, продолжительности и статусе.

   Чтобы получить более подробную информацию о потоке, выберите поток, который вы хотите исследовать, на странице Мои потоки .

   

Чтобы узнать, почему выполнение не удалось, выберите время его начала. Появится поток, а этап потока, на котором произошел сбой, будет отмечен красным восклицательным знаком. Разверните этап со сбоем, чтобы просмотреть сведения о нем. Область Дополнительные сведения справа содержит сведения о сбое, ознакомившись с которыми, вы узнаете, как устранить неполадки.

Ограничения

• Максимальное количество записей на запрос составляет 50 000, а максимальный размер данных на запрос — 32 МБ. Эти ограничения нельзя изменить.
• Время ожидания синхронных запросов — 8 минут.
• Время ожидания асинхронных запросов — 60 минут.
• Соединитель не поддерживает операторы, которые не поддерживаются оператором getschema. Например, неподдерживаемыми являются операторы fork, facet, а также evaluate.
• Потоки лучше всего выполнять в браузерах Microsoft Edge и Google Chrome.

См. также

• Используйте соединитель Приложения логики Azure Kusto для выполнения запросов и команд Kusto в рамках запланированной или активированной задачи.