Adicionar Azure Cosmos DB CDC como origem no hub em tempo real (visualização)

Este artigo descreve como adicionar o Azure Cosmos DB for NoSQL Change Data Capture (CDC) como uma fonte de eventos no hub Fabric Real-Time.

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

Nota

O hub em tempo real está atualmente em visualização.

Pré-requisitos

  • Acesso ao espaço de trabalho premium do Fabric com permissões de Colaborador ou superior.
  • Acesso a uma conta e banco de dados do Azure Cosmos DB para NoSQL .
  • Seu banco de dados do Azure Cosmos DB para NoSQL deve ser acessível publicamente e não estar protegido por um firewall ou protegido em uma rede virtual.

Obter detalhes de conexão do portal do Azure

Os rótulos dos itens que você precisa coletar do portal do Azure são mostrados nas etapas a seguir. Você sempre precisa do URI do ponto de extremidade, em um formato como https://<account>.<api>.azure.com:<port>/, a Chave Primária e o Nome do banco de dados e IDs de item para os quais deseja coletar dados.

Nota

O Azure Cosmos DB para NoSQL CDC está usando o Modo de Versão Mais Recente do Feed de Alterações do Azure Cosmos DB. Ele captura as alterações nos registros na versão mais recente. Observe que as exclusões não são capturadas com esse modo.

  1. Na página do portal do Azure para sua conta do Azure Cosmos DB, selecione Chaves em Configurações na navegação à esquerda.

  2. Na página Chaves, copie os valores de URI e Chave primária a serem usados para configurar a conexão de fluxo de eventos.

    Uma captura de tela do URI e da chave primária na página Chaves do Azure Cosmos DB no portal do Azure.

  3. Na página Visão Geral do portal do Azure para sua conta do Azure Cosmos DB, anote o Banco de Dados e a ID do item para os quais você deseja coletar dados.

    Uma captura de tela da listagem de Contêineres para uma conta de API NoSQL do Azure Cosmos DB.

Obter eventos de um CDC do Azure Cosmos DB

Você pode obter eventos de um CDC do Azure Cosmos DB para o hub em tempo real de uma das maneiras:

Iniciar Adicionar experiência de origem

  1. Entre no Microsoft Fabric.

  2. Selecione Hub em tempo real na barra de navegação esquerda.

  3. Na página do hub em tempo real, selecione + Adicionar fonte no canto superior direito da página.

    Captura de tela que mostra como iniciar o hub em tempo real no Microsoft Fabric.

Use as instruções da seção Adicionar CDC do Azure Cosmos DB como origem .

Página de fontes da Microsoft

  1. No hub em tempo real, selecione Fontes da Microsoft.

  2. Na lista suspensa Origem, selecione Azure Cosmos DB (CDC).

  3. Em Assinatura, selecione uma assinatura do Azure que tenha o grupo de recursos com sua conta do Cosmos DB.

  4. Em Grupo de recursos, selecione um grupo de recursos que tenha sua conta do Cosmos DB.

  5. Em Região, selecione um local onde o Cosmos DB está localizado.

  6. Agora, mova o mouse sobre o nome da fonte CDC do Cosmos DB 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 .

    Captura de tela que mostra a página de códigos-fonte da Microsoft com filtros para mostrar o Cosmos DB CDC e o botão conectar.

    Para configurar informações de conexão, use as etapas da seção Adicionar CDC do Azure Cosmos DB como origem . Ignore a primeira etapa de selecionar o Azure Cosmos DB CDC como um tipo de fonte no assistente Adicionar origem.

Adicionar CDC do Azure Cosmos DB como fonte

  1. Na tela Selecione uma fonte de dados, selecione Azure Cosmos DB (CDC).

    Captura de tela que mostra a página Selecionar uma fonte de dados com o Azure Cosmos DB (CDC) selecionado.

  2. Selecione Ir para o link de recurso se quiser navegar até a conta do Azure Cosmos DB no portal do Azure.

    Captura de tela que mostra a página Conectar com o link **Ir para recurso** realçado.

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

    Captura de tela que mostra a página Add source wizard Connect. com o link **Nova conexão** realçado.

  4. Na seção Configurações de conexão, especifique o ponto de extremidade do Cosmos DB. Insira o URI ou ponto de extremidade da sua conta do Cosmos DB que você copiou do portal do Azure.

    Captura de ecrã que mostra a secção Definições de ligação da página Nova ligação.

  5. Expanda Opções avançadas e siga estas etapas:

    1. Para Número de tentativas, especifique o número máximo de vezes que o conector deve retransmitir uma solicitação para o banco de dados do Cosmos DB se a solicitação falhar devido a um erro recuperável.

    2. Para Enable AVERAGE function pass down, especifique se o conector deve passar a função de agregação AVG para o banco de dados do Cosmos DB.

    3. Para Habilitar passagem SORT para várias colunas, especifique se o conector deve permitir que várias colunas sejam passadas para o banco de dados do Cosmos DB quando especificado na cláusula ORDER BY da consulta SQL.

      Captura de tela que mostra as opções avançadas para configurar o conector do Azure Cosmos DB.

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

    1. Selecione uma conexão existente e mantenha a opção padrão Criar nova conexão .
    2. Para criar uma conexão, insira os seguintes valores:
      1. Em Nome da conexão, insira um nome para a conexão.

      2. Em Tipo de autenticação, selecione Chave da conta.

      3. Em Chave de conta, insira o valor da chave que você salvou anteriormente.

      4. Selecione Ligar.

        Captura de tela que mostra a seção Credenciais de conexão da página Nova conexão.

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

    1. Especifique a ID do contêiner em sua conta do Azure Cosmos DB.

    2. Na seção Detalhes do fluxo à direita, selecione o espaço de trabalho Malha onde deseja salvar o fluxo de eventos que o Assistente vai criar.

    3. Para eventstream name, insira um nome para eventstream. O assistente cria um fluxo de eventos com o Azure Cosmos DB CDC selecionado como origem.

    4. O nome do fluxo é gerado automaticamente para você anexando -stream ao nome do fluxo de eventos. Você pode ver esse fluxo na página Todos os fluxos de dados do hub em tempo real quando o assistente terminar.

    5. Selecione Seguinte.

      Captura de ecrã que mostra a página Ligar do assistente Adicionar origem preenchida.

  8. No ecrã Rever e criar, reveja o resumo e, em seguida, selecione Criar origem.

    Captura de tela que mostra a página preenchida do assistente Adicionar código-fonte Revisar e criar.

Ver detalhes do fluxo de dados

  1. Na página Rever e criar, se selecionar Abrir fluxo de eventos, o assistente abre o fluxo de eventos que criou para si com o Azure Cosmos DB CDC selecionado como origem. Para fechar o assistente, selecione Fechar ou X* no canto superior direito da página.

    Captura de tela que mostra a página Revisar e criar após a criação bem-sucedida da fonte.

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

    Captura de tela que mostra a página Todos os fluxos de dados do hub em tempo real com o fluxo que você acabou de criar.

    Para obter etapas detalhadas, consulte Exibir detalhes de fluxos de dados no hub Fabric Real-Time.

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