Выполнение действия Wait в Фабрике данных Azure и Synapse Analytics

Статья
10/20/2023

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

Область применения:Фабрика данных Azure Azure Synapse Analytics

Совет

Попробуйте использовать фабрику данных в Microsoft Fabric, решение для аналитики с одним интерфейсом для предприятий. Microsoft Fabric охватывает все, от перемещения данных до обработки и анализа данных в режиме реального времени, бизнес-аналитики и отчетности. Узнайте, как бесплатно запустить новую пробную версию !

Создание действия Wait в пользовательском интерфейсе

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

Выполните поиск элемента Wait на панели конвейера "Действия" и перетащите действие "Wait" на холст конвейера.
Выберите новое действие "Wait" на холсте, если оно еще не выбрано, и перейдите на вкладку Параметры, чтобы изменить сведения о нем.
Введите число секунд ожидания для действия. Это может быть литеральное число, а также любое сочетание динамических выражений, функций, системных переменных или выходные данные из других действий.

Синтаксис

{
    "name": "MyWaitActivity",
    "type": "Wait",
    "typeProperties": {
        "waitTimeInSeconds": 1
    }
}

Свойства типа

Свойство	Description	Допустимые значения	Обязательное поле
name	Имя действия `Wait`.	Строка	Да
type	Для этого свойства необходимо задать значение Wait.	Строка	Да
waitTimeInSeconds	Период ожидания в секундах перед возобновлением обработки в конвейере.	Целое	Да

Пример

Примечание.

Этот раздел содержит определения JSON и примеры команд PowerShell для выполнения действий в конвейере. Пошаговые инструкции по созданию конвейера с помощью Azure PowerShell и определений JSON см. в этом руководстве.

Конвейер с действием Wait

В этом примере конвейер содержит два действия: Until и Wait. Действие Wait настроено для ожидания в течение одной секунды. Конвейер запускает веб-действие в цикле с секундным периодом ожидания между запусками.

{
    "name": "DoUntilPipeline",
    "properties": {
        "activities": [
            {
                "type": "Until",
                "typeProperties": {
                    "expression": {
                        "value": "@equals('Failed', coalesce(body('MyUnauthenticatedActivity')?.status, actions('MyUnauthenticatedActivity')?.status, 'null'))",
                        "type": "Expression"
                    },
                    "timeout": "00:10:00",
                    "activities": [
                        {
                            "name": "MyUnauthenticatedActivity",
                            "type": "WebActivity",
                            "typeProperties": {
                                "method": "get",
                                "url": "https://www.fake.com/",
                                "headers": {
                                    "Content-Type": "application/json"
                                }
                            },
                            "dependsOn": [
                                {
                                    "activity": "MyWaitActivity",
                                    "dependencyConditions": [ "Succeeded" ]
                                }
                            ]
                        },
                        {
                            "type": "Wait",
                            "typeProperties": {
                                "waitTimeInSeconds": 1
                            },
                            "name": "MyWaitActivity"
                        }
                    ]
                },
                "name": "MyUntilActivity"
            }
        ]
    }
}

Ознакомьтесь с другими поддерживаемыми действиями потока управления: