Executar a atividade de espera no Azure Data Factory e no Synapse Analytics

Artigo
10/20/2023

Quando você usa uma atividade de espera em um pipeline, o pipeline aguarda o período de tempo especificado antes de continuar com a execução de atividades subsequentes.

APLICA-SE A: Azure Data Factory Azure Synapse Analytics

Dica

Experimente o Data Factory no Microsoft Fabric, uma solução de análise tudo-em-um para empresas. O Microsoft Fabric abrange desde movimentação de dados até ciência de dados, análise em tempo real, business intelligence e relatórios. Saiba como iniciar uma avaliação gratuita!

Criar uma atividade Wait com interface do usuário

Para usar uma atividade de espera em um pipeline, siga estas etapas:

Procure Wait no painel Atividades do pipeline e arraste uma atividade de espera para a tela do pipeline.
Selecione a nova atividade de espera na tela, se ainda não estiver selecionada, e a guia Configurações para editar os detalhes.
Insira um número de segundos que a atividade deverá aguardar. Pode ser um número literal ou alguma combinação de expressões dinâmicas, funções, variáveis de sistema ou saídas de outras atividades.

Sintaxe

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

Propriedades de tipo

Propriedade	Descrição	Valores permitidos	Obrigatório
name	Nome da atividade `Wait`.	String	Sim
type	Deve ser definido para Wait.	String	Sim
waitTimeInSeconds	O número de segundos que o pipeline aguarda antes de continuar o processamento.	Integer	Sim

Exemplo

Observação

Esta seção fornece definições de JSON e comandos de exemplo do PowerShell para executar o pipeline. Para obter instruções com instruções passo a passo para criar um pipeline do usando definições de JSON e do Azure PowerShell, consulte o tutorial: criar um Data Factory usando o Azure PowerShell.

Pipeline com atividade Wait

Neste exemplo, o pipeline tem duas atividades: Until e Wait. A atividade Wait é configurada para esperar por um segundo. O pipeline executa a atividade da Web em um loop com um tempo de espera de um segundo após cada execução.

{
    "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"
            }
        ]
    }
}

Veja outras atividades de fluxo de controle com suporte: