Capturar dados alterados do Azure Data Lake Storage Gen2 para o 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
Gorjeta
Experimente o Data Factory no Microsoft Fabric, uma solução de análise tudo-em-um para empresas. O Microsoft Fabric abrange tudo, desde a movimentação de dados até ciência de dados, análises em tempo real, business intelligence e relatórios. Saiba como iniciar uma nova avaliação gratuitamente!
Neste artigo, você usa a interface do usuário do Azure Data Factory para criar um recurso CDC (captura de dados de alteração). O recurso pega 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, vai aprender a:
- Crie um recurso CDC.
- Monitore a atividade do CDC.
Você pode modificar e expandir o padrão de configuração neste artigo.
Pré-requisitos
Antes de iniciar os procedimentos neste artigo, certifique-se de que possui estes recursos:
- Subscrição do Azure. Se você não tiver uma assinatura do Azure, crie uma conta gratuita do Azure.
- Banco de dados SQL. Você usa o Banco de Dados SQL do Azure como um armazenamento de dados de origem. Se você não tiver um banco de dados SQL, crie um no portal do Azure.
- Conta de armazenamento. Você usa 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, consulte Criar uma conta de armazenamento para conhecer as etapas para criar uma.
Criar um artefato CDC
Vá para o painel Autor no seu data factory. Abaixo de Pipelines, um novo artefato de nível superior chamado Change Data Capture (visualização) é exibido.
Passe o cursor sobre Alterar captura de dados (visualização) até que três pontos apareçam. Em seguida, selecione Alterar ações de captura de dados (visualização).
Selecione Novo CDC (visualização). Esta etapa abre um submenu para iniciar o processo guiado.
Você será solicitado a nomear seu recurso CDC. Por padrão, o nome é "adfcdc" com um número que aumenta em 1. Você pode substituir esse nome padrão por um nome que você escolher.
Use a lista suspensa para escolher sua fonte de dados. Para este artigo, selecione DelimitedText.
Você será solicitado a selecionar um serviço vinculado. Crie um novo serviço vinculado ou selecione um existente.
Use a área Configurações de origem para, opcionalmente, definir configurações avançadas de origem, incluindo delimitadores de coluna e linha.
Se você não editar manualmente essas configurações de origem, elas serão definidas como padrão.
Use o botão Procurar para selecionar sua pasta de dados de origem.
Depois de selecionar um caminho de pasta, selecione Continuar para definir o destino de dados.
Você pode optar por adicionar várias pastas de origem usando o botão de adição (+). As outras fontes também devem usar o mesmo serviço vinculado que você já selecionou.
Selecione um valor de Tipo de destino usando a lista suspensa. Para este artigo, selecione Banco de Dados SQL do Azure.
Você será solicitado a selecionar um serviço vinculado. Crie um novo serviço vinculado ou selecione um existente.
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.
Para selecionar uma tabela existente, selecione a guia Entidades existentes e use a caixa de seleção para escolher uma tabela. Use o botão Visualizar para exibir os dados da tabela.
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 são criadas em Novas entidades. Além disso, você pode editar novas tabelas usando o botão Editar novas tabelas .
Você pode usar as caixas de seleção para escolher várias tabelas de destino do seu banco de dados SQL. Depois de terminar de escolher as tabelas de destino, selecione Continuar.
Uma nova guia para capturar dados de alteração é exibida. Esta guia é o estúdio CDC, onde você pode configurar seu novo recurso.
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 suspensas.
Depois de selecionar as tabelas, as colunas delas são mapeadas por padrão com a alternância de mapa automático ativada. O mapa 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 coletor suportados.
Se você quiser usar o mapa automático e não alterar nenhum mapeamento de coluna, vá diretamente para a etapa 18.
Se quiser habilitar os mapeamentos de coluna, selecione os mapeamentos e desative a alternância de mapa automático. Em seguida, selecione o botão Mapeamentos de coluna para exibir os mapeamentos.
Você pode voltar para o mapeamento automático a qualquer momento, ativando a alternância de mapa automático.
Veja os mapeamentos de coluna. Use as listas suspensas para editar os mapeamentos de coluna para o método Mapeamento, a coluna Origem e a coluna Destino.
Nesta página, pode:
- Adicione mais mapeamentos de coluna usando o botão Novo mapeamento . Use as listas suspensas para fazer seleções para o método Mapeamento, a coluna Origem e a coluna Destino.
- Selecione a coluna Chaves se quiser controlar a operação de exclusão para tipos de coletor suportados.
- Selecione o botão Atualizar em Visualização de dados para visualizar a aparência dos dados no destino.
Quando o mapeamento estiver concluído, selecione o botão de seta para retornar à tela CDC principal.
Você pode adicionar mais mapeamentos de origem para destino em um artefato CDC. 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 Mapa automático para cada um desses mapeamentos de forma independente.
Após a conclusão dos mapeamentos, defina a latência CDC usando o botão Definir latência .
Selecione a latência do CDC e, em seguida, 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 inferiores a 1 minuto.
Para outras latências (por exemplo, se você selecionar 15 minutos), a captura de dados de alteração processará os dados de origem e coletará todos os dados alterados desde o último tempo processado.
Nota
Se o suporte for estendido à integração de dados de streaming (Hubs de Eventos do Azure e fontes de dados Kafka), a latência será definida como Tempo real por padrão.
Depois de concluir a configuração do CDC, selecione Publicar tudo para publicar as alterações.
Nota
Se você não publicar suas alterações, não poderá iniciar seu recurso CDC. O botão Iniciar na próxima etapa não estará disponível.
Selecione Iniciar para começar a executar a captura de dados de alteração.
Monitore sua captura de dados de alteração
Abra o painel Monitor usando um destes métodos:
Selecione Alterar captura de dados (visualização) para visualizar seus recursos CDC.
O painel Captura de Dados de Alteração mostra as informações de Origem, Destino, Status e Última captura de dados para sua captura de dados de alteração.
Selecione o nome do seu CDC 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.
Se você configurar vários mapeamentos na captura de dados de alteração, cada mapeamento aparecerá como uma cor diferente. Selecione a barra para ver detalhes específicos para cada mapeamento ou use as informações de diagnóstico na parte inferior do painel.