Adicionar origem CDC do Banco de Dados PostgreSQL a um fluxo de eventos (visualização)

Este artigo mostra como adicionar uma fonte CDC (Change Data Capture) do banco de dados PostgreSQL a um fluxo de eventos.

O conector de origem do PostgreSQL Database Change Data Capture (CDC) para fluxos de eventos do Microsoft Fabric permite capturar um instantâneo dos dados atuais em um banco de dados PostgreSQL. Em seguida, o conector monitora e registra quaisquer alterações futuras no nível da linha nesses dados. Depois que as alterações forem capturadas no fluxo de eventos, você poderá processar esses dados CDC em tempo real e enviá-los para diferentes destinos no Fabric para processamento ou análise adicionais.

Pré-requisitos

• Acesso ao espaço de trabalho premium do Fabric com permissões de Colaborador ou superior.

• Acesso de usuário registrado no banco de dados PostgreSQL.

• Seu banco de dados PostgreSQL deve ser acessível publicamente e não estar protegido em um firewall ou protegido em uma rede virtual.

• CDC habilitado no banco de dados e tabelas PostgreSQL.

  Se você tiver o Banco de Dados do Azure para PostgreSQL, siga as etapas na próxima seção para habilitar o CDC. Para obter informações detalhadas, consulte Replicação lógica e decodificação lógica - Banco de Dados do Azure para PostgreSQL - Servidor flexível.

  Para outros bancos de dados PostgreSQL, consulte Debezium connector for PostgreSQL :: Debezium Documentation.

Habilite o CDC em seu Banco de Dados do Azure para PostgreSQL

Para habilitar o CDC em seu Banco de Dados do Azure para o Servidor Flexível PostgreSQL, siga estas etapas:

1. Na página Banco de Dados do Azure para Servidor Flexível PostgreSQL no portal do Azure, selecione Parâmetros do servidor no menu de navegação.

2. Na página Parâmetros do servidor:

   • Defina wal_level como lógico.
   • Atualize o max_worker_processes para pelo menos 16.

   

3. Salve as alterações e reinicie o servidor.

4. Confirme se a instância do Servidor Flexível do Banco de Dados do Azure para PostgreSQL permite tráfego de rede pública.

5. Conceda permissões de replicação ao usuário administrador executando a seguinte instrução SQL. Se você quiser usar outra conta de usuário para conectar seu banco de dados PostgreSQL para buscar CDC, certifique-se de que o usuário é o proprietário da tabela.

   ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
   

Adicionar o Banco de Dados do Azure para PostgreSQL CDC como uma origem

1. Selecione Eventstream para criar um novo eventstream. Certifique-se de que a opção Capacidades Avançadas (pré-visualização) está ativada.

   

2. Na tela seguinte, selecione Adicionar fonte externa.

   

Configurar e conectar-se ao Banco de Dados do Azure para PostgreSQL CDC

1. Na tela Selecionar uma fonte de dados, selecione Banco de Dados do Azure para PostgreSQL (CDC).

   

2. Na página Conectar, selecione Nova conexão.

   

3. Na seção Configurações de conexão , insira as seguintes informações.

   • Servidor: O endereço do servidor do seu banco de dados PostgreSQL, por exemplo , my-pgsql-server.postgres.database.azure.com.

   • Banco de dados: O nome do banco de dados, por exemplo , my_database.

     

4. Role para baixo e, na seção Credenciais de conexão, siga estas etapas.

   1. Em Nome da conexão, insira um nome para a conexão.

   2. Em Tipo de autenticação, selecione Básico.

      Nota

      Atualmente, os fluxos de eventos do Fabric oferecem suporte apenas à autenticação Básica .

   3. Digite Nome de usuário e senha para o banco de dados.

   4. Selecione Ligar.

      

5. Agora, na página Conectar , siga estas etapas:

   1. Para tabela, insira um nome de tabela.

   2. Em Porta, insira o número da porta ou deixe o valor padrão: 5432.

   3. Selecione Avançar na parte inferior da página.

      

6. No ecrã Rever e criar, reveja o resumo e, em seguida, selecione Adicionar.

   

Você pode ver a fonte CDC do Banco de Dados PostgreSQL adicionada ao seu fluxo de eventos no modo de edição.

Para implementar essa fonte de CDC do banco de dados PostgreSQL recém-adicionada, selecione Publicar. Depois de concluir essas etapas, sua fonte de CDC de banco de dados PostgreSQL estará disponível para visualização na Visualização dinâmica.

Conteúdos relacionados

Outros conectores:

• Amazon Kinesis Data Streams
• BD do Cosmos para o Azure
• Azure Event Hubs
• Hub IoT do Azure
• Captura de Dados de Alteração do Banco de Dados SQL do Azure (CDC)
• Kafka confluente
• Ponto de extremidade personalizado
• Google Cloud Pub/Sub
• Banco de dados MySQL CDC
• Banco de Dados PostgreSQL CDC
• Dados de exemplo
• Eventos do Armazenamento de Blobs do Azure
• Evento do espaço de trabalho de malha