Обзор действий
Эта статья поможет понять действия в Microsoft Fabric и использовать их для создания комплексных рабочих процессов на основе данных для сценариев перемещения данных и обработки данных.
Обзор
Рабочая область Microsoft Fabric может иметь один или несколько конвейеров. Конвейеры — это логические группы действий, которые вместе отвечают за выполнение задачи. Например, конвейер может содержать набор действий, вставляющих и очищающих данные журнала, а затем запускающий поток данных сопоставления для анализа данных журнала. Конвейер позволяет управлять действиями в наборе, а не каждым из них в отдельности. Вы развертываете и планируете конвейер, а не действия отдельно.
Действия в конвейере определяют действия, выполняемые с данными. Например, вы можете использовать действие копирования, чтобы скопировать данные из SQL Server в хранилище BLOB-объектов Azure. Затем используйте действие потока данных или действие Notebook для обработки и преобразования данных из хранилища BLOB-объектов в пул Azure Synapse Analytics, на основе которого создаются решения для создания отчетов бизнес-аналитики.
Microsoft Fabric имеет три типа действий: действия перемещения данных, действия преобразования данных и действия управления.
Действия перемещения данных
действие Copy в Microsoft Fabric копирует данные из исходного хранилища данных в хранилище данных приемника. Fabric поддерживает хранилища данных, перечисленные в статье обзора Подключение or. Данные из любого источника можно записывать в любой приемник.
Дополнительные сведения см. в разделе "Копирование данных с помощью действия копирования".
Действия преобразования данных
Microsoft Fabric поддерживает следующие действия преобразования, которые можно добавить отдельно или связать с другим действием.
Дополнительные сведения см. в статье Преобразование данных в фабрике данных Azure.
Действия по преобразованию данных | Вычислительная среда |
---|---|
Копирование данных | Диспетчер вычислений Microsoft Fabric |
Поток данных 2-го поколения | Диспетчер вычислений Microsoft Fabric |
Удаление данных | Диспетчер вычислений Microsoft Fabric |
Записная книжка Fabric | Кластеры Apache Spark, управляемые Microsoft Fabric |
Действие HDInsight | Кластеры Apache Spark, управляемые Microsoft Fabric |
Определение задания Spark | Кластеры Apache Spark, управляемые Microsoft Fabric |
Хранимая процедура | Azure SQL, Azure Synapse Analytics или SQL Server |
Скрипт SQL | Azure SQL, Azure Synapse Analytics или SQL Server |
Действия в потоке управления
Поддерживаются следующие действия потока управления:
Действие управления | Description |
---|---|
Добавление переменной | Добавление значения к имеющейся переменной типа “массив”. |
действие пакетная служба Azure | Запускает скрипт пакетная служба Azure. |
Действие Azure Databricks | Выполняет задание Azure Databricks (Записная книжка, Jar, Python). |
действие Машинное обучение Azure | Выполняет задание Машинное обучение Azure. |
Деактивация действия | Деактивирует другое действие. |
Не пройден | Привести к сбою выполнения конвейера с настраиваемым сообщением об ошибке и кодом ошибки. |
Фильтр | Примените выражение фильтра к входной массиву. |
ForEach | Действие ForEach определяет повторяющийся поток управления в конвейере. Это действие используется для выполнения итерации коллекции и выполняет указанные в цикле действия. Реализация цикла этого действия аналогична структуре цикла Foreach на языках программирования. |
Действие функций | Выполняет функцию Azure. |
Получение метаданных | Действие GetMetadata можно использовать для получения метаданных для любых данных в конвейере Фабрики данных Azure или Synapse. |
Если условие | Это действие можно использовать для создания ветви на основе условия, результатом расчета которого является значение True или False. Действие условия If предоставляет те же функциональные возможности, что и инструкция if в языках программирования. Оно определяет набор действий, если условие принимает значение true , и другой набор действий, если условие принимает значение false . |
Вызов конвейера | Действие Execute Pipeline позволяет конвейеру Фабрики данных или Synapse вызвать другой конвейер. |
Действие KQL | Выполняет скрипт KQL для экземпляра Kusto. |
Действие поиска | Действие поиска можно использовать для считывания или поиска записи, имени таблицы и значения из внешних источников. На эти выходные данные можно затем ссылаться в последующих действиях. |
Установка значения переменной | Установка значения существующей переменной. |
Переключение действия | Реализует выражение коммутатора, которое позволяет выполнять несколько последующих действий для каждого потенциального результата выражения. |
Действие Teams | Публикует сообщение в канале Teams или групповом чате. |
Действие Until | Реализует цикл Do Until, который аналогичен циклической структуре Do-Until в языках программирования. Оно выполняет набор действий в цикле, пока условие, связанное с действием, не получит значение true. Можно указать значение времени ожидания для действия until. |
Действие ожидания | Если в конвейере используется действие Wait, он приостанавливает обработку на указанное время, прежде чем перейти к выполнению последующих действий. |
Веб-действие | Веб-действие можно использовать для вызова из конвейера пользовательской конечной точки REST. |
Действие веб-перехватчика | С помощью действия веб-перехватчика можно вызвать конечную точку и передать URL-адрес обратного вызова. Выполнение конвейера дожидается обратного вызова, после чего переходит к следующему действию. |
Добавление действий в конвейер с помощью пользовательского интерфейса Microsoft Fabric
Чтобы добавить и настроить действия в конвейере Microsoft Fabric, выполните следующие действия.
- Создайте конвейер в рабочей области.
- На вкладке "Действия" для конвейера просмотрите отображаемые действия, прокрутите его справа, чтобы просмотреть все действия. Выберите действие, чтобы добавить его в редактор конвейера.
- При добавлении действия и выборе его на холсте редактора конвейера его общие параметры будут отображаться в области свойств под холстом.
- Каждое действие также содержит настраиваемые свойства, относящиеся к его конфигурации на других вкладках в области свойств.
Общие параметры
При добавлении нового действия в конвейер и его выборе отображаются области свойств в области в нижней части экрана. Эти области свойств включают общие, Параметры, а иногда и другие панели.
Общие параметры всегда будут содержать поля "Имя " и "Описание " для каждого действия. Некоторые действия также включают следующие действия:
Параметр | Description |
---|---|
Время ожидания | Максимальное время выполнения действия. Значение по умолчанию — 12 часов, а максимально допустимое время — семь дней. Формат времени ожидания находится в D.HH:MM:SS. |
Повторить попытку | Максимальное количество попыток повторных попыток. |
(Дополнительные свойства) Интервал повтора (с) | Количество секунд между каждой попыткой повтора. |
(Дополнительные свойства) Безопасные выходные данные | При проверка выходные данные из действия не записываются в журнале. |
(Дополнительные свойства) Безопасные входные данные | Количество секунд между каждой попыткой повтора. |
Примечание.
По умолчанию используется обратимое ограничение не более 80 действий на конвейер, включающее внутренние действия для контейнеров.