Adicionar PostgreSQL Database CDC como origem no hub em tempo real

Este artigo descreve como adicionar o PostgreSQL Database Change Data Capture (CDC) como uma fonte de eventos no hub Fabric Real-Time.

O conector de origem para captura de dados modificados (CDC) do banco de dados PostgreSQL nos fluxos de eventos do Microsoft Fabric permite capturar uma cópia instantânea dos dados atuais em um banco de dados PostgreSQL. Em seguida, o conector monitora e registra quaisquer alterações futuras nas linhas desses 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 superiores.

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

• CDC habilitado no banco de dados 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 PostgreSQL, siga estas etapas com base no seu tipo de implantação.

Base de Dados do Azure para PostgreSQL – Servidor Único

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

2. Altere a regra de replicação para Lógico.

   

Base de Dados do Azure para PostgreSQL – Servidor Flexível

1. Na página do servidor flexível Banco de Dados do Azure para 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 sua instância de 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.

   ALTER ROLE <admin user> WITH REPLICATION;
   

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

Você pode obter eventos de um Banco de Dados do Azure para PostgreSQL CDC no hub de tempo real de uma das seguintes maneiras:

• Usando a página Fontes de dados
• Usando a página de fontes da Microsoft

Página de origens de dados

1. Inicie sessão no Microsoft Fabric.

2. Se vires Power BI no canto inferior esquerdo da página, alterna para a carga de trabalho de Fabric ao selecionares Power BI e depois selecionares Fabric.

   

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

   

4. A página de dados de streaming é aberta por padrão. Clique no botão Adicionar dados para aceder à página de fontes de dados .

   

   Também pode aceder diretamente à página de fontes de dados selecionando a opção Adicionar dados na barra de navegação da esquerda.

   

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 secção Adicionar CDC 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 (CDC).

3. Em Assinatura, selecione uma assinatura do Azure que tenha o grupo de recursos com sua 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 um local onde o banco de dados está localizado.

6. Agora, mova o mouse sobre o nome da fonte CDC do Banco de Dados PostgreSQL que você deseja conectar ao hub em tempo real na lista de bancos de dados e selecione o botão Conectar ou selecione ... (reticências) e, em seguida, selecione o botão Ligar .

   

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

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

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

   

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

   

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

     

3. 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 suportam apenas a autenticação Básica .

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

   4. Selecione Ligar.

      

4. 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. Para eventstream name, insira um nome para eventstream. O assistente cria um fluxo de eventos com o CDC do Banco de Dados PostgreSQL selecionado como origem.

   4. O nome do fluxo é gerado automaticamente para você anexando -stream ao nome do fluxo de eventos. Verás este fluxo na página Todos os fluxos de dados quando o assistente terminar.

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

      

5. Na página Rever e Conectar, reveja o resumo e, em seguida, selecione Conectar.

   

Ver detalhes do fluxo de dados

1. Na página Rever + ligar, se selecionar Abrir fluxo de eventos, o assistente abre o fluxo de eventos que criou para si com o CDC da Base de Dados PostgreSQL selecionado como origem. Para fechar o assistente, selecione Concluir na parte inferior da página.

   

2. Você deve ver o fluxo na seção Dados de streaming recentes da página inicial do hubReal-Time . Para obter etapas detalhadas, consulte Exibir detalhes de fluxos de dados no hub Fabric Real-Time.

Conteúdos relacionados

Para saber mais sobre como consumir fluxos de dados, consulte os seguintes artigos:

• Processar fluxos de dados
• Analise fluxos de dados
• Definir alertas em fluxos de dados