Tilføj Oracle Database CDC-kildekode til en eventstream (forhåndsvisning)

Denne artikel viser dig, hvordan du tilføjer en Oracle Database Change Data Capture (CDC)-kilde til en eventstream.

Oracle Database CDC-kilde-connectoren til Microsoft Fabric eventstream gør det muligt at tage et øjebliksbillede af de aktuelle data i en Oracle-database. Connectoren overvåger og registrerer derefter eventuelle fremtidige ændringer af disse data på rækkeniveau. Efter ændringerne er fanget i eventstreamen, kan du behandle disse CDC-data i realtid og sende dem til forskellige destinationer inden for Fabric for yderligere behandling eller analyse. Connectoren understøtter Oracle-databaser, uanset om de er on-premises eller i skyen.

Forudsætninger

Adgang til et arbejdsområde i Fabric-kapacitetslicenstilstand eller Prøvelicens-tilstand med bidragyder eller højere tilladelser.
En kørende Oracle-databaseserver (on-premises eller cloud-hostet).
Din Oracle-database bør være offentligt tilgængelig og ikke bag en firewall eller sikret i et virtuelt netværk. Hvis den befinder sig i et beskyttet netværk, skal du forbinde til den ved at bruge Eventstream connector virtuel netværksinjektion.
Oracle LogMiner aktiveret på din database til CDC-optagelse.
En databasebruger med de nødvendige tilladelser til CDC-operationer.

Hvis du ikke har en eventstream, skal du oprette en eventstream.

Understøttede Oracle-versioner

Oracle Database CDC-connectoren understøtter følgende Oracle-databaseversioner:

Oracle Database 12c (12.1) og senere
Oracle Database 19c
Oracle Database 21c
Oracle Autonom Database

Aktivér CDC i din Oracle-database

For at indsamle ændringsdata fra Oracle skal du aktivere supplerende logning og konfigurere LogMiner.

Muliggør supplerende logning

Forbind til din Oracle-database som bruger med DBA-rettigheder.

Aktivér supplerende logning på databaseniveau ved at køre følgende SQL-kommandoer:

-- Enable minimal supplemental logging at the database level
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;

-- Enable supplemental logging for all columns (recommended for CDC)
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;

Verdsig, at supplerende logning er aktiveret:
```
SELECT SUPPLEMENTAL_LOG_DATA_MIN, SUPPLEMENTAL_LOG_DATA_ALL FROM V$DATABASE;
```
Forespørgslen bør returnere YES for begge kolonner.

Aktiver arkivelog-tilstand

For at CDC kan fungere korrekt, skal databasen være i ARCHIVELOG-tilstand.

Tjek den aktuelle arkivlog-tilstand:
```
SELECT LOG_MODE FROM V$DATABASE;
```

Hvis du ikke allerede er i ARCHIVELOG-tilstand, aktiver den:

-- Shut down the database
SHUTDOWN IMMEDIATE;

-- Start in mount mode
STARTUP MOUNT;

-- Enable archivelog mode
ALTER DATABASE ARCHIVELOG;

-- Open the database
ALTER DATABASE OPEN;

Opret en CDC-bruger med de nødvendige rettigheder

Opret en dedikeret bruger til CDC-connectoren med de nødvendige tilladelser:

-- Create a user for CDC
CREATE USER fabric_cdc IDENTIFIED BY <your_password>;

-- Grant basic privileges
GRANT CREATE SESSION TO fabric_cdc;
GRANT SELECT ON V_$DATABASE TO fabric_cdc;
GRANT SELECT ON V_$LOG TO fabric_cdc;
GRANT SELECT ON V_$LOGFILE TO fabric_cdc;
GRANT SELECT ON V_$ARCHIVED_LOG TO fabric_cdc;
GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO fabric_cdc;

-- Grant LogMiner privileges
GRANT EXECUTE ON DBMS_LOGMNR TO fabric_cdc;
GRANT EXECUTE ON DBMS_LOGMNR_D TO fabric_cdc;
GRANT SELECT ANY TRANSACTION TO fabric_cdc;
GRANT LOGMINING TO fabric_cdc;

-- Grant SELECT on tables you want to capture
GRANT SELECT ON <schema>.<table_name> TO fabric_cdc;

Erstat <your_password>, <schema>, og <table_name> med dine faktiske værdier.

Start guiden Vælg en datakilde

Hvis du endnu ikke har tilføjet nogen kilde til din eventstream, vælg flisen Connect data sources . Du kan også vælge Tilføj kilde>Connect datakilder på båndet.

Hvis du tilføjer kildekoden til en allerede offentliggjort eventstream, så skift til Rediger-tilstand . På båndet skal du vælge Tilføj kilde>Forbind datakilder.

På siden Vælg en datakilde søg efter og vælg Connect på Oracle DB (CDC) -flisen.

Konfigurér og forbind til Oracle Database CDC

På Connect-siden , i Server, indtast dit Oracle-endpoint.

Du kan kun angive værtsnavnet eller inkludere vært, port og service/SID i én værdi. Eksempel: your-oracle-host.example.com:1521/ORCL.
Under Forbindelsesoplysninger skal du vælge en eksisterende forbindelse eller oprette en ny:
- For at oprette en ny forbindelse skal du vælge Ny forbindelse og indtaste:
  - Forbindelsesnavn: Et navn for denne forbindelse.
  - Brugernavn: Oracle-databasebrugeren med CDC-tilladelser.
  - Adgangskode: Adgangskoden til databasebrugeren.
Vælg Opret forbindelse.
Når forbindelsen er etableret, vælg tabellerne, der skal optages, ved at vælge Alle tabeller eller Indtast tabelnavn(er). Hvis du vælger Indtast tabelnavn(e), indtast en valgfri komma-separeret liste af fulde tabelidentifikatorer (schemaName.tableName) til Oracle-databasetabellerne at overvåge.
Du kan udvide avancerede indstillinger for at få adgang til flere konfigurationsmuligheder for Oracle Database CDC-kilden:
- Snapshot-låsetilstand: Styrer, om og hvor længe stikket holder en bordlås. Tabellås forhindrer visse typer tabeloperationer i at finde sted, mens forbindelsen udfører et snapshot.
  - Shared (standard): Muliggør samtidig adgang til tabellen, men forhindrer nogen session i at opnå en eksklusiv tabellås. Stikket får en ROW SHARE-niveaulås, mens det opfanger tabelskemaet.
  - None: Forhindrer stikket i at opnå nogen bordlås under snapshottet. Brug kun denne indstilling, hvis der ikke sker skemaændringer under oprettelsen af snapshot.
- Decimalhåndteringstilstand: Specificerer, hvordan forbindelsen skal håndtere flydende kommatal-værdier for NUMBER, DECIMAL, og NUMERIC kolonner. Du kan indstille en af følgende muligheder:
  - Precise (standard): Repræsenterer værdier præcist ved at bruge java.math.BigDecimal værdier repræsenteret i ændringsbegivenheder i binær form.
  - Double: Repræsenterer værdier ved at bruge dobbelte værdier. At bruge dobbelte værdier er nemmere, men kan resultere i tab af præcision.
  - String: Koder værdier som formaterede strenge. At bruge muligheden String er lettere at forbruge, men resulterer i tab af semantisk information om den virkelige type.
- Snapshot-tilstand: Angiver den tilstand, som forbindelsen bruger til at tage snapshots af et optaget bord.
  - Initial (standard): Snapshot'en indeholder strukturen og dataene fra de indfangede tabeller. Angiv denne værdi for at udfylde emner med en komplet repræsentation af dataene fra de indfangede tabeller. Hvis snapshot'et gennemføres med succes, kører stikket ikke snapshot'et igen ved næste start.
  - InitialOnly: Snapshot'et inkluderer strukturen og dataene for de indfangede tabeller. Stikket udfører et indledende snapshot og stopper derefter uden at behandle efterfølgende ændringer.
  - NoData: Snapshotet indeholder kun strukturen af de indfangede tabeller. Angiv denne værdi, hvis du vil have connectoren til kun at indsamle data for ændringer, der sker efter snapshottet.
Vælg Næste for at fortsætte.
Ved Review + connect, gennemgå dine indstillinger.
Vælg Add (Eventstream) eller Connect (Real-Time hub).

Vis opdateret hændelsesstream

Du kan se Oracle Database CDC-kilden tilføjet til din eventstream i Redigeringstilstand.
For at implementere denne nyligt tilføjede Oracle Database CDC-kilde, vælg Publicér. Når du har gennemført disse trin, er din Oracle Database CDC-kilde tilgængelig til visualisering i Live-visningen.

Andre connectors:

Feedback

Var denne side nyttig?

Last updated on 2026-06-18