Jaa


SQL Serverin lisääminen VM DB (CDC) -lähteeseen tapahtumavirtaan

Tässä artikkelissa kerrotaan, miten voit lisätä SQL Serverin VM DB Change Data Capture (CDC) -lähteen tapahtumavirtaan.

Fabric-tapahtumavirtojen SQL Server on VM DB (CDC) -lähdeliittimen avulla voit siepata tilannevedoksen nykyisistä tiedoista SQL Server -tietokannassa näennäiskoneessa. Tällä hetkellä SQL Serveriä VM DB:ssä (CDC) tuetaan seuraavista palveluista, joissa tietokantoja voidaan käyttää julkisesti:

Muistiinpano

AWS RDS SQL Server, AWS RDS Custom SQL Server ja Google Cloud SQL Server eivät tue Express-versiota. Varmista, että käytät asianmukaista SQL Server for CDC -versiota.

Kun CDC:n (VM DB) SQL Server -lähde on lisätty tapahtumavirtaan, se valvoo ja kirjaa tulevat rivitason muutokset, jotka voidaan sitten käsitellä reaaliaikaisesti ja lähettää eri kohteisiin jatkoanalyyseja varten.

Edellytykset

  • Työtilan käyttöoikeus Fabric-kapasiteetin käyttöoikeustilassa (tai) kokeiluversion käyttöoikeustilassa Osallistuja-oikeudella tai korkeammilla käyttöoikeuksilla.
  • Käynnissä oleva SQL Server näennäiskonetietokannassa.
  • Näennäiskoneen tietokannassa oleva SQL Server on määritettävä sallimaan julkinen käyttö.
  • Ota CDC käyttöön SQL Serverin näennäiskonetietokannassa suorittamalla tallennettu toimintosarja sys.sp_cdc_enable_db. Lisätietoja on kohdassa Ota tietokaappaus käyttöön ja poista se käytöstä.

OTA CDC käyttöön SQL Serverissä näennäiskonetietokannassa

  1. Ota CDC käyttöön tietokannalle.

    EXEC sys.sp_cdc_enable_db; 
    
  2. Ota CDC käyttöön taulukolle gating-roolivaihtoehdon avulla. Tässä esimerkissä MyTable on SQL-taulukon nimi.

    EXEC sys.sp_cdc_enable_table 
       @source_schema = N'dbo', 
       @source_name   = N'MyTable', 
       @role_name     = NULL 
    GO 
    

    Kun kysely on suoritettu, olet ottanut CDC:n käyttöön SQL Serverin näennäiskonetietokannassa.

    Näyttökuva, jossa cdc on käytössä.

SQL Serverin lisääminen näennäiskoneeseen -tietokanta lähteeksi

  1. Luo uusi tapahtumavirta valitsemalla Fabric Real-Time Intelligence -kohdassa Eventstream .

    Näyttökuva uuden tapahtumavirran luomisesta.

  2. Valitse seuraavassa näytössä Lisää ulkoinen lähde.

    Näyttökuva Lisää ulkoinen lähde -vaihtoehdon valinnasta.

SQL Serverin määrittäminen ja siihen yhdistäminen näennäiskonetietokannassa

  1. Valitse Yhdistä-sivullaUusi yhteys.

    Näyttökuvassa näkyy Uusi yhteys -linkin valinta Yhdistä-sivulla.

  2. Anna Yhteysasetukset-osiossa seuraavat arvot SQL Serverille näennäiskoneessa:

    • Palvelin: Anna näennäiskoneesi julkisesti käytettävissä oleva IP-osoite tai toimialuenimi ja lisää sitten kaksoispiste ja portti. Jos ESIMERKIKSI IP-osoitteesi on xx.xxx.xxx.xxx ja portti on 1433, kirjoita xx.xxx.xxx.xxx:1433 Palvelin-kenttään. Jos porttia ei ole määritetty, käytetään portin oletusarvoa 1433 .

    • Tietokanta: Anna nimi tietokannalle, johon haluat muodostaa yhteyden SQL Serverissä näennäiskoneessa.

      Näyttökuvassa näkyy Yhdistä-sivun Yhteysasetukset-osa.

  3. Vieritä alaspäin ja toimi Yhteyden tunnistetiedot -osiossa seuraavien ohjeiden mukaisesti.

    • Anna yhteyden nimi Yhteyden nimi -kohtaan.

    • Valitse todennuslajiksi Perus.

      Muistiinpano

      Tällä hetkellä Fabric-tapahtumavirrat tukevat vain perustodentamista .

    • Anna SQL Serverin käyttäjänimi ja salasana näennäiskoneessa.

      Muistiinpano

      Älä valitse vaihtoehtoa: Käytä salattua yhteyttä.

      Näyttökuvassa näkyy Yhdistä-sivun Yhteyden tunnistetiedot -osa.

  4. Valitse yhdistä sivun alareunasta.

  5. Valitse nyt Yhdistä-sivullaKaikki taulukot tai Anna taulukon nimet. Jos valitset jälkimmäisen, määritä taulukot käyttämällä pilkuin eroteltua luetteloa kokonaisista taulukon tunnisteista (schemaName.tableName) tai kelvollisia säännönmukaisia lausekkeita. Esimerkkejä:

    • dbo.test.* avulla voit valita kaikki taulukot, joiden nimi alkaa dbo.test.
    • valitse dbo\.(test1|test2) ja dbo.test1dbo.test2 avulla.

    Voit yhdistellä molempia muotoiluja pilkuilla. Koko merkinnän merkkirajoitus on 102 400 merkkiä.

  6. Voit laajentaa Lisäasetukset-kohdan määrittääksesi desimaalikäsittelytilan, joka määrittää, miten liitin käsittelee ja DECIMAL sarakearvotNUMERIC:

    • Precise: Edustaa arvoja käyttäen tarkkoja desimaalityyppejä (esimerkiksi Java BigDecimal), joilla varmistetaan tietojen esityksen täysi tarkkuus ja tarkkuus.
    • Double: muuntaa arvot kaksoistarkoiksi liukupisteluvuiksi. Tämä parantaa käytettävyyttä ja suorituskykyä, mutta saattaa johtaa tarkkuuden heikkenemiseen.
    • String: Koodaa arvot muotoiltuina merkkijonoina. Tämän ansiosta niitä on helppo käyttää jatkojalostusjärjestelmissä, mutta ne menettävät semanttisia tietoja alkuperäisestä numeerisesta tyypistä.
  7. Valitse Seuraava.

    Näyttökuvassa näkyy Kaikki taulukot -asetuksen valinta.

  8. Tarkista yhteenveto Tarkistamisen + luomisen näytössä ja valitse sitten Yhdistä.

    Näyttökuvassa näkyy Lisää-painikkeen valinta.

Näytä päivitetty tapahtumavirta

Voit nähdä SQL Serverin VM DB CDC -lähteen lisättynä tapahtumavirtaasi Muokkaa-tilassa.

Näyttökuva lisätystä SQL Server -palvelimesta VM DB CDC -lähteeseen muokkaustilassa Julkaise-painike korostettuna.

Jos haluat ottaa tämän äskettäin lisätyn SQL Serverin käyttöön VM DB CDC -lähteessä, valitse Julkaise. Kun olet suorittanut nämä vaiheet, SQL Server VM DB CDC:ssä -lähde on visualisoitavissa reaaliaikaisessa näkymässä.

Näyttökuva lisätystä SQL Server -palvelimesta VM DB CDC -lähteeseen reaaliaikaisen tarkastelun tilassa.

Muut liittimet: