Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Действия — это стандартные блоки, которые помогают создавать комплексные рабочие процессы данных в 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 Machine Learning | Выполняет задание в сервисе Azure Machine Learning. |
| Деактивация действия | Деактивирует другое действие. |
| Fail | Привести к сбою выполнения конвейера с настраиваемым сообщением об ошибке и кодом ошибки. |
| Filter | Примените выражение фильтра ко входному массиву. |
| ForEach | Действие ForEach определяет повторяющийся поток управления в конвейере. Это действие используется для выполнения итерации коллекции и выполняет указанные в цикле действия. Реализация цикла этого действия аналогична структуре цикла Foreach на языках программирования. |
| Активность функций | Выполняет функцию Azure. |
| Получение метаданных | Действие GetMetadata можно использовать для получения метаданных для любых данных в конвейере Фабрики данных Azure или Synapse. |
| Если условие | Условие "If" можно использовать для ветвления на основе условия, которое оценивается как верное или ложное. Действие условия If предоставляет те же функциональные возможности, что и инструкция if в языках программирования. Оно определяет набор действий, если условие принимает значение true, и другой набор действий, если условие принимает значение false. |
| Вызов конвейера | Действие Execute Pipeline позволяет конвейеру Фабрики данных или Synapse вызвать другой конвейер. |
| Действие KQL | Выполняет скрипт KQL для экземпляра Kusto. |
| Деятельность по обслуживанию Lakehouse | Проводите плановое обслуживание таблиц в Lakehouse посредством конвейера Microsoft Fabric. |
| Операция поиска | Действие поиска можно использовать для считывания или поиска записи, имени таблицы и значения из внешних источников. На эти выходные данные можно затем ссылаться в последующих действиях. |
| Обновление действия конечной точки 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 | Сколько раз повторить, если действие завершается ошибкой. |
| (Дополнительные свойства) Интервал повтора (с) | Сколько секунд, чтобы подождать между повторными попытками. |
| (Дополнительные свойства) Безопасные выходные данные | Если выбрано, результаты активности не будут отображаться в журналах. |
| (Дополнительные свойства) Безопасные входные данные | При выборе входные данные действия не будут отображаться в журналах. |
Note
По умолчанию на конвейер можно выполнять до 120 операций. Это включает в себя внутренние действия для контейнеров.
Деактивация действия
Вы можете отключить одну или несколько активностей в конвейере, чтобы пропустить их во время проверки и выполнения конвейера. Эта функция повышает эффективность разработчика конвейера, позволяя комментировать часть конвейера, не удаляя ее с холста. Вы можете повторно активировать действия в дальнейшем.
Деактивация действий
Действие можно отключить двумя способами: деактивировать одно действие на вкладке "Общие" или деактивировать несколько действий правой кнопкой мыши.
Сохраните изменения, чтобы отключить действия во время следующего запланированного запуска конвейера.
Деактивация одного действия
- Выберите действие, которое нужно отключить
- На вкладке "Общие " выберите "Деактивировано " для состояния действия
- Выберите статус для пометить действие как. Выбор из успешного, неудачного или пропущенного
Отключение нескольких действий
- Нажмите клавишу CTRL , чтобы выбрать несколько элементов. С помощью мыши левой кнопкой щелкните на все действия, которые нужно отключить.
- Щелкните правой кнопкой мыши, чтобы открыть раскрывающееся меню
- Выберите "Деактивировать" , чтобы отключить их все
- Чтобы точно настроить параметры Отметить действие как, перейдите на вкладку Общие действия и внесите соответствующие изменения.
Повторная активация действий
Чтобы повторно активировать действия, выберите "Активировано " для состояния действия и возвращаются к их предыдущему поведению, как ожидалось.
Неактивные поведенческие модели
Неактивная активность ведет себя иначе в конвейере.
На холсте неактивное действие отображается серым цветом, и рядом с типом действия помещается индикатор неактивности.
На холсте помещается знак состояния (Успешно, Сбой или Пропущено) для визуализации параметра Отметить действие как
Операция исключается из валидации конвейера. Поэтому вам не нужно предоставлять все обязательные поля для неактивного действия.
Во время выполнения отладки и запуска конвейера действие фактически не будет выполняться. Вместо этого он выполняет замещающий элемент строки со статусом Inactive
Опция ветвления контролируется с помощью опции Отметить действие как. Другими словами:
- Если пометить действие как успешное, запускается ветвь UponSuccess или UponCompletion .
- Если пометить действие как неудачное, ветвь UponFailure или UponCompletion выполняется
- Если пометить действие как Пропущено, ветвь UponSkip запускается
Рекомендации по деактивации
Деактивация — это мощный инструмент для разработчиков конвейеров. Он позволяет разработчикам закомментировать часть кода без её окончательного удаления. Она сияет в следующих сценариях:
- При разработке конвейера разработчик может добавить неактивные действия владельца места перед заполнением всех обязательных полей. Например, мне нужно скопировать данные из SQL Server в хранилище данных, но я еще не настроил все подключения. Поэтому я использую неактивную операцию копирования в качестве заполнителя для итеративного процесса разработки.
- После развертывания разработчик может комментировать определенные действия, которые постоянно вызывают проблемы, чтобы избежать дорогостоящих повторных попыток. Например, локальный СЕРВЕР SQL Server имеет проблемы с сетевым подключением, и я знаю, что мои действия копирования завершаются сбоем. Может потребоваться деактивировать действие копирования, чтобы избежать перегрузки неустойчивой системы повторными запросами.
Note
Неактивное действие никогда не выполняется. Это означает, что действие не будет иметь поле ошибки или его типичные выходные поля. Любые ссылки на отсутствующие поля могут вызывать ошибки ниже.