Lägg till MongoDB CDC-källa i en händelseström (förhandsversion)

2025-10-10

Den här artikeln visar hur du lägger till en MongoDB-källa för ändringsdatainsamling (CDC) i en händelseström.

Med MongoDB CDC Connector för Eventstream kan du strömma CDC-händelser (Change Data Capture) från MongoDB till Fabric Eventstream. Det stöder flera MongoDB-distributionstyper, inklusive lokala, molnbaserade och MongoDB Atlas, vilket möjliggör en mängd olika CDC-scenarier. Med den här anslutningsappen kan du samla in ändringar i realtidsdatabaser och strömma dem direkt till Eventstream för omedelbar bearbetning och analys.

Anmärkning

Den här källan stöds inte i följande regioner i din arbetsytekapacitet: Västra USA3, Västra Schweiz.

Förutsättningar

En arbetsyta i läget Fabric-kapacitet eller Utvärderingslicens, med Medverkare eller högre behörigheter.
Ett MongoDB-kluster som är tillgängligt från klientens IP-adress.
Change Data Capture (CDC) aktiverad för de samlingar som du vill samla in.
En händelseström i Fabric. Om du inte har någon skapar du en händelseström.

Konfigurera en MongoDB-instans

I det här exemplet används MongoDB Atlas, den hanterade MongoDB-tjänsten på MongoDB Cloud.

Om du vill samla in ändringar måste du aktivera CDC (Change Data Capture) för målsamlingarna.

Kör följande kommando i MongoDB-gränssnittet för att aktivera CDC för en samling:

db.runCommand({
  collMod: "<collectionName>",
  changeStreamPreAndPostImages: { enabled: true }
});

Anmärkning

Du behöver en användare med atlasAdmin rollen, som innehåller åtgärden collMod, för att köra det här kommandot. Om du inte har dessa behörigheter ber du en kollega med atlasAdmin rollen att aktivera CDC (Change Data Capture) för målsamlingarna innan du samlar in ändringar i händelseströmmen.

Du måste också skapa eller använda en befintlig MongoDB-användare med read rollen (eller högre) i måldatabasen. I MongoDB Atlas på MongoDB Cloud går du till Databasåtkomst för att verifiera användarens roll.

I MongoDB Atlas på MongoDB Cloud går du till Nätverksåtkomst och lägger till klientens IP-adress i IP-åtkomstlistan.

Lägg till MongoDB (CDC) som källa

Om du inte har lagt till någon källa i händelseströmmen ännu väljer du Panelen Använd extern källa .

Om du lägger till källan i en redan publicerad händelseström växlar du till Redigeringsläge , väljer Lägg till källa i menyfliksområdet och väljer sedan Externa källor.

På sidan Välj en datakälla söker du efter och väljer Anslut på panelen MongoDB (CDC).

Konfigurera och ansluta till MongoDB (CDC)

Välj MongoDB-instanstyp: antingen MongoDB Atlas eller MongoDB (självhanterad).
Anslutning:
1. Om du väljer MongoDB Atlas:
  1. På skärmen Anslut går du till Anslutning och väljer Ny anslutning för att skapa en molnanslutning.
  2. Ange följande anslutningsinställningar och autentiseringsuppgifter för anslutning:
  - Server: Anslutningssträngen för ditt Atlas-kluster, till exempel cluster0.example.mongodb.net.
  - Kluster: Det här fältet är valfritt. Klusternamnet är redan en del av servern, så du kan lämna det här tomt.
  - Anslutningsnamn: Genereras automatiskt, eller så kan du ange ett nytt namn för den här anslutningen.
  - Användarnamn och lösenord: Autentiseringsuppgifter för en användare med minst read rollen. Kontrollera att användaren har åtkomst till måldatabasen och samlingar.
2. Om du väljer MongoDB (självhanterad):
  1. På skärmen Anslut går du till Anslutning och väljer Ny anslutning för att skapa en molnanslutning.
  2. Ange följande anslutningsinställningar och autentiseringsuppgifter för anslutning:
  - Server: Anslutningssträngen för din självhanterade MongoDB-server, till exempel mongodb0.example.com:27017.
  - Anslutningsnamn: Genereras automatiskt, eller så kan du ange ett nytt namn för den här anslutningen.
  - Användarnamn och lösenord: Använd en användare med läsbehörighet eller högre behörighet för att komma åt måldatabasen och samlingar.
Ange följande information för att konfigurera MongoDB CDC-datakällan och välj sedan Nästa.
- Databaser: Välj Alla (standard) eller Ange databasnamn. Om du väljer det senare anger du en valfri kommaavgränsad lista med reguljära uttryck som matchar databasnamnen som ska övervakas.
- Samlingar: Välj Alla (standard) eller Ange samlingsnamn. Om du väljer det senare anger du en kommaavgränsad lista med reguljära uttryck som matchar fullständigt kvalificerade namnområden (till exempel dbName.collectionName) för MongoDB-samlingarna som ska övervakas.
Du kan expandera Avancerade inställningar för att få åtkomst till fler konfigurationsalternativ för MongoDB CDC-källan:
- Läge för ögonblicksbild: Alternativen är:
  - initial (standard): Anger att anslutningsappen läser en ögonblicksbild när ingen förskjutning hittas eller om oplog-/ändringsströmmen inte längre innehåller föregående förskjutning.
  - initial_only: Anslutningsappen utför en ögonblicksbild av databasen. När ögonblicksbilden är klar stoppas kopplaren och händelseposter från efterföljande databasändringar strömmas inte.
  - no_data: Anslutningsappen avbildar strukturen för alla relevanta tabeller, men den skapar inte READ-händelser för att representera datauppsättningen vid tidpunkten för anslutningsappens start.
Du kan också redigera källnamnet genom att välja pennknappen för Källnamn i avsnittet Strömma information till höger.
På sidan Granska + anslut efter att ha granskat sammanfattningen för MongoDB CDC-källan väljer du Lägg till för att slutföra konfigurationen.

Visa uppdaterad händelseström

Du ser MongoDB-källan (CDC) som lagts till i händelseströmmen i redigeringsläge.

Du ser händelseströmmen i liveläge. Välj Redigera i menyfliksområdet för att återgå till redigeringsläget för att uppdatera händelseströmmen.

Limitation

MongoDB CDC-källan stöder för närvarande inte CI/CD-funktioner, inklusive Git-integrering och distributionspipeline. Om du försöker exportera eller importera ett Eventstream-objekt med den här källan till en Git-lagringsplats kan det leda till fel.

Andra anslutningsappar:

Feedback

Var den här sidan till hjälp?