Enviar um email com um pipeline do Azure Data Factory ou do Azure Synapse

APLICA-SE A: Azure Data Factory Azure Synapse Analytics

Muitas vezes, é necessário enviar notificações durante ou após a execução de um pipeline. A notificação fornece alertas proativos e reduz a necessidade de monitoramento reativo para descobrir problemas.  Este artigo mostra como configurar notificações por email de um pipeline do Azure Data Factory ou do Azure Synapse. 

Pré-requisitos

• Subscrição do Azure. Se não tiver uma subscrição do Azure, crie uma conta gratuita antes de começar.
• Fluxo de trabalho padrão do aplicativo lógico. Para acionar o envio de um email do pipeline, deve usar o Azure Logic Apps para configurar o fluxo de trabalho. Para obter detalhes sobre como criar um fluxo de trabalho de aplicativo lógico padrão, consulte Criar um exemplo de fluxo de trabalho de aplicativo lógico padrão.

Criar o fluxo de trabalho de email em seu aplicativo lógico

Crie um fluxo de trabalho de aplicativo lógico padrão chamado SendEmailFromPipeline. Adicione o gatilho de solicitação chamado When an HTTP request is receivede adicione a ação do Office 365 Outlook chamada Send an email (V2).

No Acionador de Solicitação, forneça este JSON para a propriedade Request Body JSON Schema.

{
    "properties": {
        "dataFactoryName": {
            "type": "string"
        },
        "message": {
            "type": "string"
        },
        "pipelineName": {
            "type": "string"
        },
        "receiver": {
            "type": "string"
        }
    },
    "type": "object"
}

O gatilho Request no designer de fluxo de trabalho deve ter esta aparência:

Para a ação Enviar um e-mail (V2), personalize como deseja formatar o e-mail, usando as propriedades do esquema JSON do corpo da solicitação:

Guarde o fluxo de trabalho. Navegue até a página Visão geral do fluxo de trabalho. Anote o URL do fluxo de trabalho, destacado na imagem abaixo:

Criar um pipeline para acionar o fluxo de trabalho da aplicação lógica.

Depois de criares o fluxo de trabalho do logic app para enviar e-mail, podes acioná-lo a partir de um pipeline usando uma atividade da Web.

1. Crie um novo pipeline e localize a atividade da Web na categoria Geral, para arrastá-la para a tela de edição.

2. Selecione a nova atividade Web1 e, em seguida, selecione o separador Configurações.

   Forneça a URL do fluxo de trabalho do aplicativo lógico que você criou anteriormente no campo URL .

   Forneça o seguinte JSON para o corpo:

      {
       "message" : "This is a custom dynamic message from your pipeline with run ID @{pipeline().RunId}.",
       "dataFactoryName" : "@{pipeline().DataFactory}", 
       "pipelineName" : "@{pipeline().Pipeline}", 
       "receiver" : "@{pipeline().parameters.receiver}"
      }
   

   Use expressões dinâmicas para gerar mensagens úteis para eventos em seus pipelines. Observe que o formato JSON aqui corresponde ao formato JSON definido no aplicativo lógico e você também pode personalizá-los conforme necessário.

   

3. Selecione a área de fundo do editor de pipeline para acessar a página de propriedades do pipeline e adicionar um novo parâmetro chamado destinatário, definindo um endereço de e-mail como o seu valor padrão.

   Neste exemplo, fornecemos o e-mail do destinatário a partir de um parâmetro de pipeline que definimos arbitrariamente. O valor do recetor pode ser retirado de qualquer expressão, ou mesmo fontes de dados ligadas.

   

4. Publique seu pipeline e acione-o manualmente para confirmar que o e-mail foi enviado conforme o esperado.

   

Adicionar mensagens dinâmicas com variáveis e expressões do sistema

Você pode usar variáveis e expressões do sistema para tornar suas mensagens dinâmicas. Por exemplo:

• @activity("CopyData").output.errors[0].Message

• @activity("DataFlow").error.Message

As expressões acima retornarão as mensagens de erro relevantes de uma falha da atividade de cópia, que podem ser redirecionadas para a sua atividade Web que envia o e-mail. Consulte o artigo Copiar propriedades de saída da atividade para obter mais detalhes.