Adicionar CDA do Banco de Dados PostgreSQL como origem no hub em tempo real

Este artigo descreve como adicionar a captura de dados de alterações (CDA) do Banco de Dados PostgreSQL como uma origem do evento no hub em tempo real do Fabric.

O conector de origem da CDA (captura de dados de alterações) do Banco de Dados PostgreSQL para Eventstreams 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.

Pré-requisitos

• Acesso a um espaço de trabalho no modo de licença de capacidade do Fabric (ou) no modo de licença de Avaliação com permissões de Colaborador ou superior.

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

• CDA habilitada no Banco de Dados 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.

Observação

Não há suporte para a CDA de várias tabelas.

Habilitar A CDA no Banco de Dados do Azure para PostgreSQL

Para habilitar a CDA no Banco de Dados do Azure para PostgreSQL, siga as etapas a seguir com base no seu tipo de implantação.

Servidor único do Banco de Dados do Azure para PostgreSQL

1. Vá para a página Duplicação no portal do Azure.

2. Altere a regra de duplicação para Lógica.

   

Servidor flexível do Banco de Dados do Azure para PostgreSQL

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.

   ALTER ROLE <admin user> WITH REPLICATION;
   

Obter eventos de um CDC do Banco de Dados do Azure para PostgreSQL

Você pode obter eventos de um CDC do Banco de Dados do Azure para PostgreSQL no Hub em Tempo Real de uma destas maneiras:

• Uso da página Fontes de dados
• Uso da página Fontes da Microsoft

Página fontes de dados

1. Entre no Microsoft Fabric.

2. Selecione Tempo Real na barra de navegação esquerda.

3. Na página Hub em Tempo Real, selecione + Fontes de dados em Conectar-se a no menu de navegação à esquerda. Você também pode acessar a página Fontes de dados nas páginas Todos os fluxos de dados ou Meus fluxos de dados, selecionando o botão + Conectar fonte de dados no canto superior direito.

   

4. Na página Fontes de dados, selecione a categoria Fontes da Microsoft na parte superior e selecione Conectar no bloco Banco de Dados do Azure para PostgreSQL (CDC).

   

   Use as instruções da seção Adicionar CDA do Banco de Dados PostgreSQL como origem.

Página de fontes da Microsoft

1. No Hub em Tempo Real, selecione Fontes da Microsoft.

2. Na lista suspensa Origem, selecione PostgreSQL (CDA).

3. Em Assinatura, selecione uma assinatura do Azure que tenha o grupo de recursos com a conta do Banco de Dados PostgreSQL.

4. Em Grupo de recursos, selecione um grupo de recursos que tenha o banco de dados.

5. Em Região, selecione uma localização do banco de dados.

6. Agora, passe o mouse sobre o nome da origem da CDA do Banco de Dados PostgreSQL que deseja conectar ao hub em tempo real na lista de bancos de dados; selecione o botão Conectar ou as ... (reticências) e depois Conectar.

   

   Para configurar as informações de conexão, use as etapas da seção Adicionar o CDC do Banco de Dados do Azure para PostgreSQL como origem.

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

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

   

   Se você tiver uma conexão existente à origem de CDC do Banco de Dados do Azure para PostgreSQL, você poderá selecioná-la na lista suspensa Conexão e ir para a configuração de porta e tabelas.

   

2. 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.

     

3. 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 Eventstreams do Fabric dão suporte apenas à autenticação Básica.

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

   4. Selecione Conectar.

      

4. 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. Em nome do eventstream, insira um nome para o Eventstream. O assistente cria um Eventstream com a CDA do Banco de Dados PostgreSQL selecionada como origem.

   4. O Nome do fluxo é gerado automaticamente para você acrescentando -stream ao nome do Eventstream. Você verá esse fluxo na página Todos os fluxos de dados, quando o assistente for concluído.

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

      

5. Na página Examinar e conectar, examine o resumo e selecione Conectar.

   

Exibir detalhes do fluxo de dados

1. Na página Examinar e conectar, se você selecionar Abrir Eventstream, o assistente abrirá o Eventstream criado para você com o CDC do Banco de Dados PostgreSQL selecionado como origem. Para fechar o assistente, selecione Concluir na parte inferior da página.

   

2. No hub em tempo real, selecione Meus fluxos de dados. Para ver o novo fluxo de dados, atualize a página.

   

Conteúdo relacionado

Para saber mais sobre consumo de fluxos de dados, confira os seguintes artigos:

• Processamento de fluxos de dados
• Análise de fluxos de dados
• Defina alertas sobre fluxos de dados