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

  • Artigo

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:

  1. Procure Wait no painel Atividades do pipeline e arraste uma atividade de espera para a tela do pipeline.

  2. Selecione a nova atividade de espera na tela, se ainda não estiver selecionada, e a guia Configurações para editar os detalhes.

    Shows the UI for a Wait activity.

  3. 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"
            }
        ]
    }
}

Conteúdo relacionado

Veja outras atividades de fluxo de controle com suporte: