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

Внимание

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

Соединитель 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 выберите Мои потоки>+ Новый поток.

    Снимок экрана: Power Automate домашняя страница с выделенными потоками и

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

    Снимок экрана: диалоговое окно

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

    Снимок экрана: страница создания запланированного потока с выделенными параметрами имени потока.

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

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

    Снимок экрана: окно выбора операции с выделенным полем поиска и Azure Data Explorer.

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

    Внимание

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

    Снимок экрана: список действий

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

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

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

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

Примечание.

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

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

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

Пример

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

Снимок экрана: соединитель Azure Data Explorer, показывающий действие запроса KQL.

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

Примечание.

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

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

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

Пример

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

Снимок экрана: соединитель Azure Data Explorer, показывающий запрос запуска KQL и отрисовку действия диаграммы.

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

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

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

Пример

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

Снимок экрана: соединитель Azure Data Explorer с действием команды запуска асинхронного управления.

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

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

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

Снимок экрана: команда

Выполнение команды "Показать управление"

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

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

Пример

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

Снимок экрана: соединитель Azure Data Explorer, показывающий действие команды

Отправка результатов запроса 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.

    Снимок экрана: подключение Azure Data Explorer с параметром проверки подлинности.

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

    Снимок экрана: подключение Azure Data Explorer с параметром входа.

Проверка подлинности

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

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

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

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

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

    Примечание.

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

    Снимок экрана: подключение Azure Data Explorer с диалоговым окном проверки подлинности приложения.

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

    Снимок экрана: завершенная проверка подлинности приложения.

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

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

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

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

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

    Снимок экрана: главное Power Automate меню, в котором выделены мои потоки.

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

    Снимок экрана: вкладка

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

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

    Снимок экрана: страница с подробными сведениями результатов журнала выполнения.

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

Снимок экрана: запуск потока с сообщением об ошибке.

Ограничения

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