Jaa

Real-Time tietojen opetusohjelma, osa 3: Tietojen muuntaminen KQL-tietokannassa

  • Artikkeli

Muistiinpano

Tämä opetusohjelma on osa sarjaa. Katso edellisestä osiosta ohjeet artikkelista Real-Time -tietojen opetusohjelma, osa 2: Tietojen noutaminen Real-Time keskittimeen.

Tässä opetusohjelman osassa opit käyttämään päivityskäytäntöä tietojen muuntamiseen Real-Time intelligence -tietokannassa. Päivityskäytännöt ovat automaatiomekanismeja, jotka käynnistyvät, kun uusia tietoja kirjoitetaan taulukkoon. Ne poistavat erityisorkestroinnin tarpeen suorittamalla kyselyn, joka muuntaa käsiteltävät tiedot ja tallentaa tuloksen kohdetaulukkoon. Yhteen taulukkoon voidaan määrittää useita päivityskäytäntöjä, jolloin voidaan tehdä erilaisia muunnoksia ja tallentaa tietoja useisiin taulukoihin samanaikaisesti. Kohdetaulukoilla voi olla erilainen rakenne, säilytyskäytäntö ja muut käytännöt lähdetaulukosta.

Raakatietotaulukon siirtäminen pronssikansioon

Tässä vaiheessa siirrät raakadatataulukon pronssikansioon tietojen järjestämiseksi KQL-tietokantaan.

  1. Selaa edellisessä vaiheessa luomaasi KQL-tietokantaan, jonka nimi on Tutorial.

  2. Valitse objektipuusta KQL-tietokannan nimi -kohdasta kyselytyötila nimeltä Tutorial_queryset.

  3. Kopioi tai liitä seuraava komento taulukon muokkaamiseksi ja taulukon siirtämiseksi Pronssi-kansioon.

    .alter table RawData (BikepointID:string,Street:string,Neighbourhood:string,Latitude:dynamic,Longitude:dynamic,No_Bikes:long,No_Empty_Docks:long,Timestamp:datetime) with (folder="Bronze")

Luo kohdetaulukko

Tässä vaiheessa luot kohdetaulukon, johon tallennetaan päivityskäytännöllä muunnetut tiedot.

  1. Luo seuraava komento kopioimalla tai liittämalla uusi taulukko nimeltä TransformedData käyttäen määritettyä rakennetta.

    .create table TransformedData (BikepointID: int, Street: string, Neighbourhood: string, Latitude: dynamic, Longitude: dynamic, No_Bikes: long, No_Empty_Docks: long, Timestamp: datetime, BikesToBeFilled: long, Action: string) with (folder="Silver")

  2. Luo taulukko suorittamalla komento. Näet nyt toisen taulukon Tables -solmun alla objektipuussa nimeltä TransformedData.

Luo funktio muunnoslogiikalla

Tässä vaiheessa luot tallennetun funktion, joka sisältää päivityskäytännössä käytettävän muunnoslogiikan. Funktio jäsentää BikepointID sarakkeen ja lisää kaksi uutta laskettua saraketta.

  1. Valitse valikkovalintanauhasta Tietokanta-.

  2. Valitse +New>Function.

  3. Muokkaa funktiota niin, että se vastaa seuraavaa koodia, tai kopioi/liitä seuraava komento kyselyeditoriin.

    .create-or-alter function TransformRawData() {
RawData
| parse BikepointID with * "BikePoints_" BikepointID:int
| extend BikesToBeFilled = No_Empty_Docks - No_Bikes
| extend Action = iff(BikesToBeFilled > 0, tostring(BikesToBeFilled), "NA")
 }

  4. Luo funktio suorittamalla komento. Sinun pitäisi nyt nähdä TransformRawDatafunktioFunctions -solmun alla objektipuussa.

Käytä päivityskäytäntöä

Tässä vaiheessa otat käyttöön päivityskäytännön kohdetaulukossa tietojen muuntamista varten. Päivityskäytäntö käyttää tallennettua funktiota TransformRawData()BikepointID -sarakkeen jäsentämiseen ja lisää kaksi uutta laskettua saraketta.

  1. Valitse valikkovalintanauhasta Tietokanta-.

  2. Valitse + Uusi>Taulukon päivityskäytäntö -.

  3. Muokkaa käytäntöä niin, että se vastaa seuraavaa koodia, tai kopioi/liitä seuraava komento kyselyeditoriin.

    .alter table TransformedData policy update
```[{
    "IsEnabled": true,
    "Source": "RawData",
    "Query": "TransformRawData()",
    "IsTransactional": false,
    "PropagateIngestionProperties": false
}]```

  4. Luo päivityskäytäntö suorittamalla komento.

Tarkista muunnos

Tässä vaiheessa voit varmistaa muunnoksen onnistumisen vertaamalla lähde- ja kohdetaulukoiden tuloksia.

Muistiinpano

Tietojen näkeminen muunnetussa taulukossa voi kestää muutamia sekunteja.

  1. Kopioi tai liitä seuraava kysely kyselyeditoriin, jotta voit tarkastella kymmentä satunnaista tietuetta lähdetaulukossa. Suorita kysely.

    RawData
| take 10

  2. Kopioi tai liitä seuraava kysely kyselyeditoriin, jotta voit tarkastella 10 satunnaista tietuetta kohdetaulukossa. Suorita kysely.

    TransformedData
| take 10

Huomaa, että kohdetaulukon BikepointID-sarake ei enää sisällä etuliitettä "BikePoints_".

Aiheeseen liittyvä sisältö

Lisätietoja tässä opetusohjelmassa suoritettavista tehtävistä on seuraavissa tehtävissä:

Seuraava vaihe

Real-Time -opetusohjelma, osa 4: Tietojen suoratoisto KQL- avulla