Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Действия — это стандартные блоки, которые помогают создавать комплексные рабочие процессы данных в Microsoft Fabric. Думайте о них как о задачах, которые перемещают и преобразуют данные в соответствии с вашими бизнес-потребностями. Можно использовать действие копирования для перемещения данных из SQL Server в хранилище BLOB-объектов Azure. Затем можно добавить действие потока данных или действие Notebook для обработки и преобразования данных перед загрузкой данных в Azure Synapse Analytics для создания отчетов.
Подсказка
Узнайте, как визуально создавать и перемещать конвейеры на холсте. Дополнительные сведения см. в разделе Холст конвейера.
Действия группируются в конвейерах для достижения конкретных целей. Например, можно создать конвейер, который:
- Получение данных журнала из различных источников
- Очистка и упорядочение данных
- Выполняет анализ для поиска данных.
Группирование действий в конвейер позволяет управлять всеми этими шагами как одной единицей, а не обрабатывать каждое действие отдельно. Вы можете одновременно развернуть и запланировать весь поток данных, чтобы он запускался, когда вам это нужно.
Microsoft Fabric предлагает три типа действий:
- Действия по перемещению данных — перемещение данных между системами
- Действия по преобразованию данных — обработка и преобразование данных
- Управление потоком выполнения - Управляйте процессом выполнения вашего конвейера
Действия перемещения данных
Эти действия помогают перемещать данные из одного места в другой в конвейере.
| Активность движения | Description |
|---|---|
| Копирование данных | Данные можно скопировать из любого поддерживаемого источника в любое поддерживаемом месте назначения. Ознакомьтесь с обзором соединителя , чтобы узнать, что доступно. |
| Копировать задание | Задания копирования — это упрощенный метод для быстрого перемещения данных. |
Если вам нужно выбрать различные варианты перемещения данных, ознакомьтесь со статьей руководства по перемещению данных .
Действия преобразования данных
Эти действия помогают обрабатывать и преобразовывать данные. Их можно использовать отдельно или связать их друг с другом с другими действиями.
Дополнительные сведения см. в статье Мероприятия по преобразованию данных.
| Действия по преобразованию данных | Среда вычислений |
|---|---|
| Копирование данных | Диспетчер вычислений 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. |
| Деактивация действия | Деактивирует другое действие. |
| Fail | Привести к сбою выполнения конвейера с настраиваемым сообщением об ошибке и кодом ошибки. |
| Filter | Примените выражение фильтра ко входному массиву. |
| ForEach | Действие ForEach определяет повторяющийся поток управления в конвейере. Это действие используется для выполнения итерации коллекции и выполняет указанные в цикле действия. Реализация цикла этого действия аналогична структуре цикла Foreach на языках программирования. |
| Активность функций | Выполняет функцию Azure. |
| Получение метаданных | Действие GetMetadata можно использовать для получения метаданных для любых данных в конвейере Фабрики данных Azure или Synapse. |
| Если условие | Условие "If" можно использовать для ветвления на основе условия, которое оценивается как верное или ложное. Действие условия If предоставляет те же функциональные возможности, что и инструкция if в языках программирования. Оно определяет набор действий, если условие принимает значение true, и другой набор действий, если условие принимает значение false. |
| Вызов конвейера | Действие Execute Pipeline позволяет конвейеру Фабрики данных или Synapse вызвать другой конвейер. |
| Действие KQL | Выполняет скрипт KQL для экземпляра Kusto. |
| Деятельность по обслуживанию Lakehouse | Проводите плановое обслуживание таблиц в Lakehouse посредством конвейера Microsoft Fabric. |
| Операция поиска | Действие поиска можно использовать для считывания или поиска записи, имени таблицы и значения из внешних источников. На эти выходные данные можно затем ссылаться в последующих действиях. |
| Обновление действия "Материализованное озеро" | Обновляет материализованное представление озера в Lakehouse, чтобы отразить последние данные. |
| Обновление действия конечной точки SQL | Обновляет конечную точку SQL Lakehouse, чтобы отразить последние данные. |
| Установка переменной | Установка значения существующей переменной. |
| Переключение действия | Реализует оператор переключения, который позволяет выполнять несколько последовательных действий для каждого возможного результата. |
| Активность Teams | Публикует сообщение в канале Teams или групповом чате. |
| До начала действия | Реализует цикл Do Until, который аналогичен циклической структуре Do-Until в языках программирования. Оно выполняет набор действий в цикле, пока условие, связанное с действием, не получит значение true. Можно указать значение времени ожидания для действия until. |
| Активность ожидания | Если в конвейере используется действие Wait, он приостанавливает обработку на указанное время, прежде чем перейти к выполнению последующих действий. |
| Веб-действие | Веб-активность можно использовать для вызова пользовательской конечной точки REST из конвейера. |
| Активность вебхука | С помощью действия веб-перехватчика можно вызвать конечную точку и передать URL-адрес обратного вызова. Запуск конвейера ожидает вызова обратной связи, прежде чем перейти к следующему действию. |
Добавление действий в конвейер с помощью пользовательского интерфейса Microsoft Fabric
Вот как добавить и настроить активности в конвейере:
- Создайте конвейер в рабочей области.
- Перейдите на вкладку "Действия" и просмотрите доступные действия. Прокрутите право, чтобы просмотреть все параметры, а затем выберите действие, чтобы добавить его в редактор конвейера.
- При добавлении действия и выборе его на холсте вы увидите его общие параметры в области свойств ниже.
- Каждое действие имеет другие параметры конфигурации на других вкладках в области свойств.
Общие параметры
При добавлении нового действия в конвейер и его выборе вы увидите его свойства в нижней части экрана. К ним относятся общие, параметры и иногда другие вкладки.
Каждое действие включает поля "Имя " и "Описание " в общих параметрах. Некоторые действия также имеют следующие варианты:
| Setting | Description |
|---|---|
| Timeout | Как долго действие может выполняться до истечения времени ожидания. Значение по умолчанию — 12 часов, а максимальное — семь дней. Используйте формат D.HH:MM:SS. |
| Включение повторных попыток | Если этот параметр выбран, при сбое автоматически выполняется повторная попытка операции. |
| Retry | Сколько раз повторить, если действие завершается ошибкой. По умолчанию равен 1. |
| Условия повтора (предварительная версия) | Настройте определенные условия ошибки, которые активируют повторную попытку. |
| Интервал повтора (с) | Сколько секунд, чтобы подождать между повторными попытками. Значение по умолчанию — 30 секунд. |
| (Дополнительные свойства) Безопасные выходные данные | Если выбрано, результаты активности не будут отображаться в журналах. |
| (Дополнительные свойства) Безопасные входные данные | При выборе входные данные действия не будут отображаться в журналах. |
Note
По умолчанию на конвейер можно выполнять до 120 операций. Это включает в себя внутренние действия для контейнеров.
Повторная попытка действия
Если действие завершается сбоем во время выполнения конвейера, его можно настроить для автоматического повтора, прежде чем пометить выполнение как сбой. Эта функция полезна для обработки кратковременных сбоев, таких как сетевые тайм-ауты, временная недоступность службы или периодически возникающие проблемы с подключением.
Настройка параметров повтора
Чтобы настроить поведение повторных попыток для действия, выполните следующие действия.
- Выберите действие на холсте конвейера.
- На вкладке "Общие " области свойств установите флажок "Включить повторные попытки ", чтобы включить функцию повторных попыток.
- Задайте для поля повторных попыток число попыток. Введите значение от 1 до 1000. Значение по умолчанию — 1.
- При необходимости настройте условия повтора (предварительная версия) для управления выполнением повторных попыток на основе определенных критериев ошибки.
- Задайте для поля интервал повторных попыток (с), чтобы определить количество секунд ожидания между повторными попытками. Значение по умолчанию — 30 секунд.
Настройка условий повторных попыток (предварительная версия)
По умолчанию действие повторяется при любом сбое. Используйте условия повтора , чтобы указать точно, какие ошибки должны активировать повторную попытку. Это помогает избежать напрасных повторных попыток при ошибках, которые не будут устранены, например при ошибках аутентификации.
Чтобы добавить условие повтора, выполните приведенные действия.
- В разделе "Условия повторных попыток" (предварительная версия) нажмите + кнопку, чтобы добавить новую строку условия.
- Выберите поле для вычисления:
- Сообщение об ошибке: текстовое содержимое сообщения об ошибке.
- Тип сбоя: категория сбоя (например, ошибка пользователя, системная ошибка).
- Код ошибки: возвращается конкретный код ошибки (например, 429 для ограничения скорости).
- Выберите оператор, чтобы определить тип соответствия (например, "Содержит").
- Введите значение для сопоставления.
- Используйте столбец And/Or для объединения нескольких условий. Выберите И, чтобы требовать совпадения всех условий, или Или, чтобы повторить попытку, если совпадает хотя бы одно условие.
Например, чтобы повторять попытку только при ошибках ограничения скорости, добавьте условие, где Field имеет значение Error code, Operator — Contains, а Value — 429.
Important
Интервал повтора выполняется перед вычислением условия. Например, если установить интервал между повторными попытками в 1 час и условие для повторной попытки не выполняется, конвейер всё равно будет ждать целый час, прежде чем перейти к следующему действию или завершить выполнение конвейера.
Подсказка
Если условия повторных попыток не указаны, действие повторяется при любых сбоях. Добавьте условия, чтобы точнее определять, какие ошибки должны приводить к повторным попыткам.
Известные ограничения повторных попыток
- Поддержка операций: Условные повторные попытки доступны для определённых типов действий, включая копирование данных, записную книжку, поток данных и действия хранимых процедур.
- Свойства ошибки: условия повторных попыток могут соответствовать коду ошибки, сообщению об ошибке и типу сбоя. Для сопоставления доступны не все поля ошибок, относящихся к соединителю.
Деактивация действия
Вы можете отключить одну или несколько активностей в конвейере, чтобы пропустить их во время проверки и выполнения конвейера. Эта функция повышает эффективность разработчика конвейера, позволяя комментировать часть конвейера, не удаляя ее с холста. Вы можете повторно активировать действия в дальнейшем.
Деактивация действий
Действие можно отключить двумя способами: деактивировать одно действие на вкладке "Общие" или деактивировать несколько действий правой кнопкой мыши.
Сохраните изменения, чтобы отключить действия во время следующего запланированного запуска конвейера.
Деактивация одного действия
- Выберите действие, которое нужно отключить
- На вкладке "Общие " выберите "Деактивировано " для состояния действия
- Выберите статус для пометить действие как. Выбор из успешного, неудачного или пропущенного
Отключение нескольких действий
- Нажмите клавишу CTRL , чтобы выбрать несколько элементов. С помощью мыши левой кнопкой щелкните на все действия, которые нужно отключить.
- Щелкните правой кнопкой мыши, чтобы открыть раскрывающееся меню
- Выберите "Деактивировать" , чтобы отключить их все
- Чтобы точно настроить параметры Отметить действие как, перейдите на вкладку Общие действия и внесите соответствующие изменения.
Повторная активация действий
Чтобы повторно активировать действия, выберите "Активировано " для состояния действия и возвращаются к их предыдущему поведению, как ожидалось.
Неактивные поведенческие модели
Неактивная активность ведет себя иначе в конвейере.
На холсте неактивное действие отображается серым цветом, и рядом с типом действия помещается индикатор неактивности.
На холсте помещается знак состояния (Успешно, Сбой или Пропущено) для визуализации параметра Отметить действие как
Операция исключается из валидации конвейера. Поэтому вам не нужно предоставлять все обязательные поля для неактивного действия.
Во время выполнения отладки и запуска конвейера действие фактически не будет выполняться. Вместо этого он выполняет замещающий элемент строки со статусом Inactive
Опция ветвления контролируется с помощью опции Отметить действие как. Другими словами:
- Если пометить действие как успешное, запускается ветвь UponSuccess или UponCompletion .
- Если пометить действие как неудачное, ветвь UponFailure или UponCompletion выполняется
- Если пометить действие как Пропущено, ветвь UponSkip запускается
Рекомендации по деактивации
Деактивация — это мощный инструмент для разработчиков конвейеров. Он позволяет разработчикам закомментировать часть кода без её окончательного удаления. Она сияет в следующих сценариях:
- При разработке конвейера разработчик может добавить неактивные действия владельца места перед заполнением всех обязательных полей. Например, мне нужно скопировать данные из SQL Server в хранилище данных, но я еще не настроил все подключения. Поэтому я использую неактивную операцию копирования в качестве заполнителя для итеративного процесса разработки.
- После развертывания разработчик может комментировать определенные действия, которые постоянно вызывают проблемы, чтобы избежать дорогостоящих повторных попыток. Например, локальный СЕРВЕР SQL Server имеет проблемы с сетевым подключением, и я знаю, что мои действия копирования завершаются сбоем. Может потребоваться деактивировать действие копирования, чтобы избежать перегрузки неустойчивой системы повторными запросами.
Note
Неактивное действие никогда не выполняется. Это означает, что действие не будет иметь поле ошибки или его типичные выходные поля. Любые ссылки на отсутствующие поля могут вызывать ошибки ниже.