Adicionar origem da CDA do Banco de Dados PostgreSQL a um Eventstream (preview)

Este artigo mostra como adicionar uma origem da captura de dados de alterações do Banco de Dados PostgreSQL (CDA) a um Eventstream.

O conector de origem da captura de dados de alterações (CDA) do Banco de Dados PostgreSQL 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 eventstream, você poderá processar esses dados da CDA em tempo real e enviá-los a 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 Contribuidor ou superiores.

• Acesso de usuário registrado no Banco de Dados PostgreSQL.

• O Banco de Dados PostgreSQL deve ser publicamente acessível e não estar por trás de um firewall ou protegido em uma rede virtual.

• CDA habilitada no Banco de Dados e tabelas PostgreSQL.

  Caso tenha o Banco de Dados do Azure para PostgreSQL, siga as etapas na próxima seção para habilitar a CDA. Para obter informações detalhadas, confira Duplicação lógica e decodificação lógica no Banco de Dados do Azure para PostgreSQL – Servidor Flexível.

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

Habilitar A CDA no Banco de Dados do Azure para PostgreSQL

Para habilitar o CDA em seu servidor flexível do Banco de Dados do Azure para PostgreSQL, siga essas etapas:

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

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

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

   

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

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

5. Conceda ao usuário administrador permissões para executar a instrução SQL a seguir. Se você quiser usar outra conta de usuário para conectar seu banco de dados PostgreSQL para efetuar fetch de CDC, verifique se o usuário é o proprietário da tabela.

   ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
   

Adicionar a CDA do Banco de Dados do Azure para PostgreSQL como origem

1. Selecione Eventstream para criar um eventstream. Verifique se a opção Recursos Avançados (preview) está habilitada.

   

2. Na tela seguinte, selecione Adicionar origem externa.

   

Configurar e conectar-se à CDA do Banco de Dados do Azure para PostgreSQL

1. Na tela Selecionar uma fonte de dados, escolha BD do Azure para PostgreSQL (CDA).

   

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

   

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

   • 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 as etapas a seguir.

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

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

      Observação

      Atualmente, os fluxos de eventos do Fabric são compatíveis apenas com a autenticação Básica.

   3. Insira o Nome de usuário e a Senha do banco de dados.

   4. Selecione Conectar.

      

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

   1. Em Tabela, insira o nome da 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. Na tela Revisar e criar, revise o resumo e selecione Adicionar.

   

Você pode ver a origem da CDA do Banco de Dados PostgreSQL adicionada ao Eventstream no Modo de edição.

Para implementar essa origem recém-adicionada da CDA do BD para PostgreSQL, selecione Publicar. Depois de concluir essas etapas, a origem da CDA do BD para PostgreSQL estará disponível para visualização na Exibição ao vivo.

Conteúdo relacionado

Outros conectores:

• Amazon Kinesis Data Streams
• Azure Cosmos DB
• Hubs de eventos do Azure
• Hub IoT do Azure
• Captura de dados de alterações (CDA) com o Banco de Dados SQL do Azure
• Kafka para Confluent
• Ponto de extremidade personalizado
• Pub/Sub do Google Cloud
• CDA do Banco de Dados MySQL
• CDA do Banco de dados PostgreSQL
• Dados de amostra
• Eventos de Armazenamento de Blobs do Azure
• Evento de espaço de trabalho do Fabric