Compartilhar via


Módulo 3: Automatizar e enviar notificações com o Data Factory

Você pode concluir este módulo em cerca de 10 minutos. Nesta parte final do nosso tutorial, você aprenderá a enviar um email notificando você quando todos os trabalhos em um pipeline estiverem concluídos e configurar o pipeline para ser executado em um agendamento.

Pré-requisitos

Módulo 1 desta série de tutoriais: Criar um pipeline com o Data Factory

Adicionar uma atividade do Outlook do Office 365 ao pipeline

  1. Abra o pipeline que você criou no Módulo 1: criar um pipeline no Data Factory.

  2. Selecione a guia Atividades no editor de pipeline e localize a atividade do Office Outlook.

    Captura de tela mostrando a seleção da atividade do Outlook do Office 365 na barra de ferramentas Atividades no menu do editor de pipeline.

  3. Selecione a nova atividade do Office Outlook e selecione sua guia Configurações .

  4. Entre em sua conta do Office se você ainda não fez isso e, quando solicitado, conceda consentimento para usar seu endereço de email.

    Captura de tela mostrando a caixa de diálogo Escolher uma conta.

    Observação

    No momento, o serviço não dá suporte a emails pessoais. Você deve usar um endereço de email corporativo.

  5. Selecione e arraste o caminho De êxito (um ícone de seleção verde no canto superior direito da atividade no painel de atividades do pipeline) da sua atividade Copiar para sua nova atividade do Outlook do Office 365.

    Captura de tela mostrando a conexão da saída de sucesso da atividade Copy com a nova atividade do Outlook do Office 365.

  6. Selecione a atividade do Outlook do Office 365 na tela do pipeline e, em seguida, selecione a guia Configurações da área de propriedade abaixo da tela para configurar o email.

    • Insira seu endereço de email na seção Para . Se você quiser usar vários endereços, use ; para separá-los.
    • Para o Assunto, selecione o campo para que a opção Adicionar conteúdo dinâmico seja exibida e selecione-o para exibir a tela do construtor de expressões de pipeline.

    Captura de tela mostrando a configuração da guia configurações de email do Outlook do Office 365.

  7. Aparece a caixa de diálogo do construtor de expressões do pipeline. Insira a seguinte expressão e selecione OK:

    @concat('Pipeline DI em uma Hora Concluído com Id de Execução do Pipeline', pipeline().RunId)

    Captura de tela mostrando o construtor de expressões de pipeline com a expressão fornecida para a linha de assunto do email.

  8. Para o Corpo, selecione o campo novamente e escolha a opção Adicionar conteúdo dinâmico quando ele aparecer abaixo da área de texto. Adicione a seguinte expressão novamente (com seu próprio nome de atividade de cópia) no construtor de expressões de pipeline na caixa de diálogo exibida e selecione OK:

    @concat('RunID = ', pipeline().RunId, ' ; ', 'Linhas copiadas ', activity('Copy data1').output.rowsCopied, ' ; ','Taxa de transferência ', activity('Copy data1').output.throughput)

    Importante

    Substitua Copiar dados1 pelo nome de sua própria atividade de cópia de pipeline.

  9. Por fim, selecione a guia Página Inicial na parte superior do editor de pipeline e escolha Executar. Em seguida, selecione Salvar e executar novamente na caixa de diálogo de confirmação para executar essas atividades.

    Captura de tela mostrando a janela do editor de pipeline com o botão Executar realçado no menu.

  10. Depois que o pipeline for executado com êxito, verifique seu email para encontrar o email de confirmação enviado do pipeline.

    Captura de tela mostrando o status do pipeline quando ele é concluído.

    Captura de tela mostrando o email gerado pelo pipeline.

Agendar a execução do pipeline

Depois de concluir o desenvolvimento e o teste do pipeline, você poderá agendá-lo para ser executado automaticamente.

  1. Na guia Página Inicial da janela do editor de pipeline, selecione Agendamento.

    Uma captura de tela do botão Agendar no menu da guia Página Inicial no editor de pipeline.

  2. Configure o agendamento conforme necessário. O exemplo aqui agenda o pipeline para ser executado diariamente às 20h até o final do ano.

    Captura de tela mostrando a configuração de agendamento de um pipeline a ser executado diariamente às 20h até o final do ano.

(Opcional) Adicionar uma atividade de fluxo de dados ao pipeline

Você também pode adicionar o fluxo de dados criado no Módulo 2: Criar um fluxo de dados no Data Factory no pipeline.

  1. Passe o mouse sobre a linha verde que conecta a atividade Copiar e a atividade do Outlook do Office 365 na tela do pipeline e selecione o + botão para inserir uma nova atividade.

    Captura de tela mostrando o botão para inserir atividade para a conexão entre a atividade Copiar e a atividade do Outlook do Office 365 no canvas do pipeline.

  2. Escolha o fluxo de dados no menu exibido.

    Captura de tela mostrando a seleção de Dataflow no menu de atividade de inserção no painel do pipeline.

  3. A atividade de fluxo de dados recém-criada é inserida entre a atividade Copy e a atividade do Outlook do Office 365 e selecionada automaticamente, mostrando suas propriedades na área abaixo da tela. Selecione a guia Configurações na área de propriedades e selecione o fluxo de dados criado no Módulo 2: Criar um fluxo de dados no Data Factory.

    Captura de tela mostrando a guia Configurações da atividade fluxo de dados.

Em nosso tutorial de ponta a ponta para seu primeiro pipeline de integração de dados usando o Data Factory no Microsoft Fabric, você aprendeu a:

  • Use uma atividade de cópia para ingerir dados não processados de um repositório de origem em uma tabela em um Lakehouse de dados.
  • Use uma atividade de fluxo de dados para processar os dados e movê-los para uma nova tabela no Lakehouse.
  • Use uma atividade do Outlook do Office 365 para enviar um email notificando você depois que todos os trabalhos forem concluídos.
  • Configure o pipeline para ser executado em uma base agendada.
  • (Opcional) Insira uma atividade de fluxo de dados em um fluxo de pipeline existente.

Agora que você concluiu o tutorial, você está pronto para criar seus próprios pipelines e fluxos. Você também pode saber mais sobre como monitorar execuções de pipelines: