Atividade de webhook no Azure Data Factory

APLICA-SE A: Azure Data Factory Azure Synapse Analytics

Uma atividade do webhook pode controlar a execução dos pipelines pelo código personalizado. Com a atividade do webhook, o código pode chamar um ponto de extremidade e passá-lo para uma URL de retorno de chamada. A execução do pipeline aguarda o retorno da chamada antes de prosseguir para a próxima atividade.

Criar uma atividade de Webhook com a interface do usuário

Para usar uma atividade Webhook em um pipeline, conclua as seguintes etapas:

1. Procure Webhook no painel Atividades do pipeline e arraste uma atividade Webhook para a tela do pipeline.

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

   

3. Especifique um URL para o Webhook, que pode ser uma string URL literal ou qualquer outra combinação de expressões dinâmicas, variáveis do sistema ou saídas de outras atividades. Forneça outros detalhes a serem enviados com a solicitação.

4. Use a saída da atividade como a entrada para qualquer outra atividade e faça referência à saída em qualquer lugar que o conteúdo dinâmico tem suporte na atividade de destino.

Sintaxe

{
    "name": "MyWebHookActivity",
    "type": "WebHook",
    "typeProperties": {
        "method": "POST",
        "url": "<URLEndpoint>",
        "headers": {
            "Content-Type": "application/json"
        },
        "body": {
            "key": "value"
        },
        "timeout": "00:10:00",
        "reportStatusOnCallBack": false,
        "authentication": {
            "type": "ClientCertificate",
            "pfx": "****",
            "password": "****"
        }
    }
}

Propriedades de tipo

Autenticação

Uma atividade do webhook dá suporte aos seguintes tipos de autenticação.

Nenhum

Se a autenticação não for necessária, não inclua a propriedade de autenticação.

Básico

Especifique o nome de usuário e a senha a serem usados com a autenticação básica.

"authentication":{
   "type":"Basic",
   "username":"****",
   "password":"****"
}

Certificado do cliente

Especifique o conteúdo codificado em Base64 de um arquivo PFX e uma senha.

"authentication":{
   "type":"ClientCertificate",
   "pfx":"****",
   "password":"****"
}

Identidade gerenciada

Especifique o URI do recurso para o qual o token de acesso será solicitado usando a identidade gerenciada para a instância do workspace do data factory ou do Synapse. Para chamar a API de Gerenciamento de Recursos Azure, use https://management.azure.com/. Para obter mais informações sobre como as identidades gerenciadas funcionam, consulte a visão geral de identidades gerenciadas para recursos do Azure.

"authentication": {
    "type": "MSI",
    "resource": "https://management.azure.com/"
}

Observações adicionais

O serviço passa a propriedade adicional callBackUri no corpo enviado para o ponto de extremidade do URL. O serviço espera que essa URI seja chamada antes do valor de tempo limite especificado. Se a URI não for chamado, a atividade falhará com o status "TimedOut".

A atividade do webhook falha quando a chamada para o ponto de extremidade personalizado falha. Qualquer mensagem de erro pode ser adicionada ao corpo do retorno de chamada e usada em uma atividade posterior.

Para cada chamada à API REST, o cliente atinge o tempo limite se o ponto de extremidade não responder dentro de um minuto. Esse comportamento é a melhor prática de HTTP padrão. Para corrigir esse problema, implemente um padrão 202. No caso atual, o ponto de extremidade retorna 202 (Aceito) e o cliente pesquisa.

O tempo limite de um minuto na solicitação não tem nada a ver com o tempo limite da atividade. O último é usado para aguardar o retorno de chamada especificado por callbackUri.

O corpo devolvido à URI de retorno de chamada deve ser um JSON válido. Defina o cabeçalho Content-Type como application/json.

Ao usar a propriedade Relatar status no retorno de chamada, você deve adicionar o seguinte código ao corpo ao fazer o retorno de chamada:

{
    "Output": {
        // output object is used in activity output
        "testProp": "testPropValue"
    },
    "Error": {
        // Optional, set it when you want to fail the activity
        "ErrorCode": "testErrorCode",
        "Message": "error message to show in activity error"
    },
    "StatusCode": "403" // when status code is >=400, activity is marked as failed
}

Conteúdo relacionado

Há suporte para as seguintes atividades de fluxo de controle:

• Atividade If Condition
• Atividade Execute Pipeline
• Atividade For Each
• Atividade Get Metadata
• Atividade Lookup
• Atividade Web
• Atividade Until