Adicionar o CDC do Azure Cosmos DB como origem no hub em tempo real (preview)

Este artigo descreve como adicionar a captura de dados de alterações (CDA) do Azure Cosmos DB for NoSQL como uma origem do evento no hub Fabric em tempo real.

( conector de origem de captura de dados de alterações (CDC) 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 as alterações futuras nesses dados em nível de linha. Depois que as alterações são capturadas em um fluxo, você pode processar esses dados da CDA em tempo real e enviá-los a diferentes destinos no Fabric para processamento ou análise adicionais.

Observação

Atualmente, o hub em tempo real está em preview.

Pré-requisitos

• Acesso ao espaço de trabalho premium do Fabric com permissões de Contribuidor ou superiores.
• Acesso a uma conta e a um banco de dados do Azure Cosmos DB for NoSQL.
• O seu banco de dados do Azure Cosmos DB for NoSQL deve ser acessível publicamente e não estar protegido por um firewall ou ter a segurança de uma rede virtual.

Obter os detalhes de conexão no 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>/, da Chave Primária, do Nome do banco de dados e das IDs de item para os quais deseja coletar dados.

Observação

A CDA do Azure Cosmos DB for NoSQL está usando a Última Versão do Modo do Feed de Alterações do Azure Cosmos DB. Ele captura as alterações nos registros na última versão. Observe que as Exclusões não são capturadas neste modo.

1. Na página do portal do Azure da 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 do Eventstream.

   

3. Na página de Visão geral do portal do Azure da sua conta do Azure Cosmos DB, observe o Banco de dados e a ID do item para os quais deseja coletar dados.

   

Obter eventos de um CDC do Azure Cosmos DB

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

• Usando a experiência Adicionar origem
• Usando a página de fontes da Microsoft

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.

   

Use as instruções da seção Adicionar CDA 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 (CDA).

3. Para 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 seu Cosmos DB está localizado.

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

   

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

Adicionar Azure Cosmos DB CDA como origem

1. Na tela Selecionar uma fonte de dados, selecione Azure Cosmos DB (CDA).

   

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

   

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

   

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

   

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

   1. Em 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. Em Habilitar passagem de função MÉDIA, especifique se o conector deve passar a função de agregação do AVG para o banco de dados do Cosmos DB.

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

      

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, use os seguintes valores:

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

      2. Para Tipo de Autenticação, selecione a Chave de conta.

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

      4. Selecione Conectar.

         

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

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

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

   3. Para nome do fluxo de eventos, insira um nome para fluxo de eventos. O assistente cria um fluxo de eventos com o CDA do Azure Cosmos DB 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 for concluído.

   5. Selecione Avançar.

      

8. Na tela Revisar e criar, revise o resumo e selecione Criar origem.

   

Ver detalhes do fluxo de dados

1. Na página Revisar e criar, se você selecionar Abrir fluxo de eventos, o assistente abrirá o fluxo de eventos criado para você com o CDA do Azure Cosmos DB selecionado como origem. Para fechar o assistente, selecione Fechar ou X* no canto superior direito da página.

   

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.

   

   Para obter etapas detalhadas, confira View details of data streams in Fabric Real-Time hub.

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