Capturar dados alterados do Azure Data Lake Storage Gen2 para Banco de Dados SQL do Azure usando um recurso de captura de dados de alteração

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!

Neste artigo, você usa a interface do usuário do Azure Data Factory para criar um recurso de CDA (captura de dados de alteração). O recurso coleta dados alterados de uma fonte do Azure Data Lake Storage Gen2 e os adiciona ao Banco de Dados SQL do Azure em tempo real.

Neste artigo, você aprenderá como:

  • Crie um recurso de CDA.
  • Monitore a atividade de CDA.

Você pode modificar e expandir o padrão de configuração neste artigo.

Pré-requisitos

Antes de iniciar os procedimentos deste artigo, certifique-se de ter estes recursos:

  • Assinatura do Azure. Caso não tenha uma assinatura do Azure, crie uma conta gratuita do Azure.
  • Banco de dados SQL. Use o Banco de Dados SQL do Azure como armazenamento de dados de origem. Se você não tiver um banco de dados SQL, crie um no portal do Azure.
  • Conta de armazenamento. Use o Delta Lake armazenado no Azure Data Lake Storage Gen2 como um armazenamento de dados de destino. Se você não tiver uma conta de armazenamento, confira Criar uma conta de armazenamento para obter as etapas para criar uma.

Criar um artefato de CDA

  1. Vá para o painel Autor em seu data factory. Abaixo de Pipelines, um novo artefato de nível superior chamado Captura de Dados de Alterações (versão prévia) é exibido.

    Screenshot of a new top-level artifact for change data capture on the Factory Resources pane.

  2. Passe o mouse sobre a Captura de Dados de Alterações (versão prévia) até que três pontos apareçam. Em seguida, selecione Ações da Captura de Dados de Alterações (versão prévia).

    Screenshot of the button for change data capture actions appearing over the new top-level artifact.

  3. Selecione o Novo CDA (versão prévia). Essa etapa abre um submenu para iniciar o processo guiado.

    Screenshot of a list of change data capture actions.

  4. Você será solicitado a nomear o recurso de CDA. Por padrão, o nome é "adfcdc" com um número incrementado em 1. Você pode substituir esse nome padrão por um nome escolhido.

    Screenshot of the text box to update the name of a resource.

  5. Use a lista de seleção para escolher sua fonte de dados. Para este artigo, selecione DelimitedText.

    Screenshot of the guided process flyout with source options in a dropdown list.

  6. Em seguida, você será solicitado a selecionar um serviço vinculado. Crie um serviço vinculado ou selecione um existente.

    Screenshot of the box to choose or create a linked service.

  7. Use a área Configurações de origem para definir opcionalmente as configurações avançadas de origem, incluindo delimitadores de coluna e de linha.

    Screenshot of advanced source settings to set delimiters.

    Se você não editar manualmente essas configurações de origem, elas serão definidas como padrões.

  8. Use o botão Procurar para selecionar sua pasta de dados de origem.

    Screenshot of a folder icon to browse for a folder path.

  9. Depois de selecionar um caminho da pasta, selecione Continuar para definir seu destino de dados.

    Screenshot of the Continue button in the guided process to select data targets.

    Você pode optar por adicionar várias pastas de origem usando o botão de adição (+). As outras origens também devem usar o mesmo serviço vinculado que você já selecionou.

  10. Selecione um valor de Tipo de destino usando a lista de seleção. Para este artigo, selecione Banco de Dados SQL do Azure.

    Screenshot of a dropdown menu of all data target types.

  11. Em seguida, você será solicitado a selecionar um serviço vinculado. Crie um serviço vinculado ou selecione um existente.

    Screenshot of the box to choose or create a linked service to your data target.

  12. Para Tabelas de destino, você pode criar uma nova tabela de destino ou selecionar uma existente:

    • Para criar uma tabela de destino, selecione a guia Novas entidades e, em seguida, selecione Editar novas tabelas.

      Screenshot of the tab to create new tables for your target.

    • Para selecionar uma tabela existente, selecione a guia Entidades existentes e use a caixa de seleção para escolher uma tabela. Use botão Visualizar permite exibir os dados da tabela.

      Screenshot of the tab to choose tables for your target.

    Se as tabelas existentes no destino tiverem nomes correspondentes, elas serão selecionadas por padrão em Entidades existentes. Caso contrário, novas tabelas com nomes correspondentes serão criadas em Novas entidades. Além disso, você pode editar novas tabelas usando o botão Editar novas tabelas.

  13. Você pode usar as caixas de seleção para escolher várias tabelas de destino do banco de dados SQL. Depois de concluir a escolha das tabelas de destino, selecione Continuar.

    Screenshot of the Continue button in the guided process to proceed to the next step.

  14. Uma nova guia para capturar dados de alteração será exibida. Essa guia é o estúdio de CDA, no qual você pode configurar seu novo recurso.

    Screenshot of the change data capture studio.

    Um novo mapeamento é criado automaticamente para você. Você pode atualizar as seleções Tabela de Origem e Tabela de Destino para seu mapeamento usando as listas de seleção.

    Screenshot of the source-to-target mapping in the change data capture studio.

  15. Depois de selecionar suas tabelas, suas colunas são mapeadas por padrão com a alternância Mapeamento automático ativada. O Mapeamento automático mapeia automaticamente as colunas por nome no coletor, seleciona novas alterações de coluna quando o esquema de origem evolui e flui essas informações para os tipos de coletores suportados.

    Se você quiser usar oMapeamento automático e não alterar nenhum mapeamento de coluna, vá diretamente para a etapa 18.

    Screenshot of the toggle for automatic mapping turned on.

    Se você quiser habilitar os mapeamentos de coluna, selecione os mapeamentos e desative a alternância Mapeamento automático. Em seguida, selecione o botão Mapeamentos de coluna para visualizar os mapeamentos.

    Screenshot of mapping selection, the toggle for automatic mapping turned off, and the button for column mappings.

    Você pode voltar para o mapeamento automático a qualquer momento ativando a alternância Mapeamento automático.

  16. Exiba seus mapeamentos de coluna. Use as listas de seleção para editar os mapeamentos de coluna para Método de mapeamento, Coluna de origem e Coluna de destino.

    Screenshot of the page for editing column mappings.

    Nesta página, você pode:

    • Adicione mais mapeamentos de coluna usando o botão Novo mapeamento. Use as listas de seleção para selecionar Método de mapeamento, Coluna de origem e Coluna de destino.
    • Selecione a coluna Chaves se quiser rastrear a operação de exclusão dos tipos de coletor com suporte.
    • Selecione o botão Atualizar em Visualização de dados para visualizar a aparência dos dados no destino.

    Screenshot of the button for adding column mappings, the dropdown list for mapping methods, the Keys column, and the Refresh button.

  17. Quando o mapeamento estiver concluído, selecione o botão de seta para retornar à tela principal de CDA.

    Screenshot of the button to go back to the table mapping page.

  18. Você pode adicionar mais mapeamentos de origem para destino em um artefato de CDA. Use o botão Editar para adicionar mais fontes de dados e destinos. Em seguida, selecione Novo mapeamento e use as listas suspensas para definir uma nova origem e destino. Você pode ativar ou desativar o Mapeamento automático para cada um desses mapeamentos independentemente.

    Screenshot of the button to add new sources and the button to set a new source-to-target mapping.

  19. Ao concluir os mapeamentos, defina a latência de CDA usando o botão Definir Latência.

    Screenshot of the Set Latency button at the top of the canvas.

  20. Selecione a latência de CDA e selecione Aplicar para fazer as alterações.

    Por padrão, a latência é definida como 15 minutos. O exemplo neste artigo usa a opção Em tempo real para latência. A latência em tempo real capta continuamente as alterações nos dados de origem em intervalos de menos de 1 minuto.

    Para outras latências (por exemplo, se você selecionar 15 minutos), sua captura de dados de alterações processará seus dados de origem e selecionará todos os dados alterados desde o último horário processado.

    Screenshot of the options for setting latency.

    Observação

    Se o suporte for estendido para integração de dados de streaming (fontes de dados dos Hubs de Eventos do Azure e do Kafka), a latência será definida como Tempo real por padrão.

  21. Depois de concluir a configuração de CDA, selecione Publicar tudo para publicar suas alterações.

    Screenshot of the publish button at the top of the canvas.

    Observação

    Se você não publicar suas alterações, não poderá iniciar seu recurso de CDA. O botão Iniciar na próxima etapa não estará disponível.

  22. Selecione Iniciar para começar a executar a captura de dados de alterações.

    Screenshot of the Start button at the top of the canvas.

Monitorar a captura de dados de alterações

  1. Abra o painel Monitorar usando um destes métodos:

    • No portal do Azure, selecione Monitorar.

      Screenshot of the Monitor button in the Azure portal.

    • Selecione o ícone de monitoramento no designer de CDA.

      Screenshot of the monitoring icon at the top of the CDC canvas.

  2. Selecione Captura de Dados de Alterações (versão prévia) para exibir seus recursos da CDA.

    Screenshot of the Change Data Capture button.

    O painel Captura de Dados de Alterações mostra a Origem, o Destino, o Status e as informações Processadas pela última vez para a captura de dados de alterações.

    Screenshot of an overview of the change data capture monitoring page.

  3. Selecione o nome da CDA para ver mais detalhes. Você pode ver quantas alterações (inserir, atualizar ou excluir) foram lidas e gravadas, juntamente com outras informações de diagnóstico.

    Screenshot of the detailed monitoring of a selected change data capture.

    Se você configurar vários mapeamentos em sua captura de dados de alterações, cada mapeamento aparecerá com uma cor diferente. Selecione a barra para ver os detalhes específicos de cada mapeamento ou use as informações de diagnóstico na parte inferior do painel.

    Screenshot of the detailed monitoring information for a change data capture with multiple source-to-target mappings.

    Screenshot of a detailed breakdown of each mapping in a change data capture artifact.