Tapahtumien käsitteleminen SQL-operaattorin avulla (esiversio)

SQL-operaattori (esikatselu), jota kutsutaan myös SQL-koodieditoriksi, on uusi tietojen muunnosominaisuus Microsoft Fabric -tapahtumavirroissa. SQL-operaattorit tarjoavat koodin muokkauskokemuksen, jossa voit helposti määrittää oman mukautetun tietojen muunnoslogiikan yksinkertaisten SQL-lausekkeiden avulla. Tässä artikkelissa kuvataan, miten voit käyttää SQL-operaattoria tapahtumavirran tietomuunnoksiin.

Note

Eventstream-artefaktien nimet, jotka sisältävät alaviivan (_) tai pisteen (.) eivät ole yhteensopivia SQL-operaattoreiden kanssa. Parhaan käyttökokemuksen saat luomalla uuden tapahtumavirran käyttämättä alaviivoja tai pisteitä artefaktin nimessä.

Prerequisites

• Työtilan käyttö Fabric-kapasiteetin käyttöoikeustilassa tai kokeilukäyttöoikeustilassa osallistujan tai sitä suuremmilla käyttöoikeuksilla.

SQL-operaattorin lisääminen tapahtumavirtaan

Jos haluat suorittaa virtakäsittelytoimintoja tietovirroissasi SQL-operaattorin avulla, lisää SQL-operaattori tapahtumavirtaan seuraavien ohjeiden mukaisesti:

1. Luo uusi tapahtumavirta. Lisää sitten siihen SQL-operaattori jollakin seuraavista vaihtoehdoista:

   • Valitse valintanauhassa Muunna tapahtumat ja valitse sitten SQL.

     

   • Valitse pohjassa Muunna tapahtumat tai Lisää kohde ja valitse sitten SQL Code.

     

2. Uusi SQL-solmu lisätään tapahtumavirtaan. Valitse kynäkuvake jatkaaksesi SQL-operaattorin määrittämistä.

   

3. Määritä SQL Code -ruudussa yksilöllinen nimi SQL-operaattorisolmulle tapahtumavirrassa.

4. Muokkaa kyselyä kyselyalueella tai valitse Muokkaa kyselyä , jos haluat siirtyä koko näytön koodieditorinäkymään.

   

5. Koko näytön koodieditoritilassa on tulo-/tulostehallintaruutu vasemmalla puolella. Koodieditoriosio on säädettävissä, joten voit muuttaa sen kokoa mieltymystesi mukaan. Alareunassa olevassa esikatseluosiossa voit tarkastella sekä syötetietojasi että kyselysi testitulosta.

   

6. Valitse Tulosteet-osan teksti ja kirjoita sitten kohdesolmun nimi. SQL-operaattori tukee kaikkia Real-Time Intelligence -kohteita, kuten tapahtumataloa, lakehousea, aktivaattoria tai streamia.

   

7. Määritä alias tai nimi tulostekohteelle, johon SQL-operaattorin kautta käsitellyt tiedot kirjoitetaan.

   

8. Lisää SQL-kysely vaadittua tietojen muunnosta varten.

   Tapahtumavirta on rakennettu Azure Stream Analyticsin päälle, ja se tukee samaa kyselysemantiikkaa kuin Stream Analytics -kyselykieli. Lisätietoja syntaksista ja käytöstä on artikkelissa Azure Stream Analyticsin ja Eventstreamin kyselyn kieliviittaus.

   Tässä on kyselyn perusrakenne:

   SELECT 
   
       column1, column2, ... 
   
   INTO 
   
       [output alias] 
   
   FROM 
   
       [input alias] 
   

   Tämä kyselyesimerkki näyttää huoneen korkeiden lämpötilojen havaitsemisen minuutin välein:

   
       SELECT 
       System.Timestamp AS WindowEnd, 
       roomId, 
       AVG(temperature) AS AvgTemp 
   INTO 
       output 
   FROM 
       input 
   GROUP BY 
       roomId, 
       TumblingWindow(minute, 1) 
   HAVING 
       AVG(temperature) > 75 
   

   Tässä kyselyesimerkissä on CASE lauseke lämpötilan luokittelua varten:

   SELECT
       deviceId, 
       temperature, 
       CASE  
           WHEN temperature > 85 THEN 'High' 
           WHEN temperature BETWEEN 60 AND 85 THEN 'Normal' 
           ELSE 'Low' 
       END AS TempCategory 
   INTO 
       CategorizedTempOutput 
   FROM 
       SensorInput 
   

9. Vahvista muunnoslogiikka valintanauhassa Testaa kysely -komennolla. Testikyselyn tulokset näkyvät Testitulos-välilehdessä .

   

10. Kun olet lopettanut testauksen, palaa tapahtumavirran pohjaan valitsemalla valintanauhassa Tallenna .

    

11. Jos Tallenna-painike on käytössä SQL Code -ruudussa, tallenna asetukset valitsemalla se.

    

12. Määritä kohde.

    

Limitations

• SQL-operaattori on suunniteltu keskittämään kaikki muunnoslogiikkasi. Tämän seurauksena et voi käyttää sitä muiden saman käsittelypolun sisäisten operaattoreiden rinnalla. Useiden SQL-operaattoreiden ketjutusta yhteen polkuun ei myöskään tueta. Lisäksi SQL-operaattori voi lähettää tulostietoja vain topologian kohdesolmuun.

• Tällä hetkellä tapahtumavirran topologioiden luomista tuetaan vain käyttöliittymän kautta. SQL-operaattorin REST-ohjelmointirajapinnan tuki ei ole vielä käytettävissä.

Liittyvä sisältö

• Kohteen lisääminen ja hallinta tapahtumavirran aikana