Del via

Behandle hændelser ved hjælp af en SQL-operator (prøveversion)

En SQL-operator (prøveversion), også kaldet en SQL-kodeeditor, er en ny datatransformationsfunktion i Microsoft Fabric-hændelsesstrømme. SQL-operatorer giver en koderedigeringsoplevelse, hvor du nemt kan definere din egen brugerdefinerede datatransformationslogik ved hjælp af enkle SQL-udtryk. I denne artikel beskrives det, hvordan du bruger en SQL-operator til datatransformationer i en hændelsesstrøm.

Note

Eventstream-artefaktnavne, der indeholder et understregningstegn (_) eller et punktum (.), er ikke kompatible med SQL-operatorer. Du får den bedste oplevelse ved at oprette en ny eventstream uden at bruge understregningstegn eller prikker i artefaktnavnet.

Prerequisites

  • Adgang til et arbejdsområde i Fabric-kapacitetslicenstilstanden eller prøvelicenstilstanden med bidragyder eller højere tilladelser.

Føje en SQL-operator til en hændelsesstrøm

Hvis du vil udføre strømbehandlingshandlinger på dine datastrømme ved hjælp af en SQL-operator, skal du føje en SQL-operator til din eventstream ved hjælp af følgende instruktioner:

  1. Opret en ny eventstream. Føj derefter en SQL-operator til den ved hjælp af en af følgende indstillinger:

    • Vælg Transformér hændelser på båndet, og vælg derefter SQL.

      Skærmbillede, der viser valget af en SQL-operator i menuen til transformering af hændelser.

    • Vælg Transformér hændelser eller tilføj destination på lærredet, og vælg derefter SQL Code.

      Skærmbillede, der viser valget af en SQL-operator på listen til transformering af hændelser på lærredet.

  2. Der føjes en ny SQL-node til din eventstream. Vælg blyantikonet for at fortsætte med at konfigurere SQL-operatoren.

    Skærmbillede, der viser valget af blyantsikonet på SQL-operatornoden.

  3. I ruden SQL Code skal du angive et entydigt navn til SQL-operatornoden i eventstream.

  4. Rediger forespørgslen i forespørgselsområdet, eller vælg Rediger forespørgsel for at åbne visningen af kodeeditoren i fuld skærm.

    Skærmbillede, der viser feltet til indtastning af et handlingsnavn og knappen til redigering af en forespørgsel i SQL-koderuden.

  5. Fuldskærmskoderedigeringstilstanden har en input/output-stifinderrude i venstre side. Kodeeditorsektionen er justerbar, så du kan ændre størrelsen på den efter dine præferencer. Eksempelsektionen nederst giver dig mulighed for at få vist både dine inputdata og din forespørgsels testresultat.

    Skærmbillede, der viser SQL Full Editor.

  6. Markér teksten i sektionen Output , og angiv derefter et navn til destinationsnoden. SQL-operatoren understøtter alle Real-Time Intelligence-destinationer, herunder et eventhouse, søhus, aktivator eller stream.

    Skærmbillede, der viser området Output med plusknappen valgt.

  7. Angiv et alias eller navn til outputdestinationen, hvor de data, der behandles via SQL-operatoren, skrives.

    Skærmbillede, der viser navnet på et output.

  8. Tilføj SQL-forespørgsel for den påkrævede datatransformation.

    En eventstream er bygget oven på Azure Stream Analytics, og den understøtter den samme forespørgselsemantik som Stream Analytics-forespørgselssproget. Du kan få mere at vide om syntaksen og brugen under Azure Stream Analytics og Eventstream Query Language Reference.

    Her er den grundlæggende forespørgselsstruktur:

    SELECT 

    column1, column2, ... 

INTO 

    [output alias] 

FROM 

    [input alias]

    I dette forespørgselseksempel vises registreringen af høje temperaturer i et rum hvert minut:

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

    I dette forespørgselseksempel vises en CASE sætning til kategorisering af temperatur:

    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. Brug kommandoen Test forespørgsel på båndet til at validere transformationslogikken. Testforespørgselsresultater vises under fanen Testresultat .

    Skærmbillede, der viser et testresultat.

  10. Når du er færdig med at teste, skal du vælge Gem på båndet for at vende tilbage til eventstream-lærredet.

    Skærmbillede, der viser båndet for en forespørgsel, herunder kommandoer til test af forespørgslen og lagring.

  11. Hvis knappen Gem er aktiveret i ruden SQL Code, skal du vælge den for at gemme indstillingerne.

    Skærmbillede, der viser SQL-koderuden og knappen Gem.

  12. Konfigurer destinationen.

    Skærmbillede, der viser en fuldført eventstream.

Limitations

  • SQL-operatoren er designet til at centralisere al din transformationslogik. Derfor kan du ikke bruge den sammen med andre indbyggede operatorer inden for den samme behandlingssti. Sammenkædning af flere SQL-operatorer i en enkelt sti understøttes heller ikke. Derudover kan SQL-operatoren kun sende outputdata til destinationsnoden i topologien.

  • I øjeblikket understøttes oprettelse af eventstream-topologier kun via brugergrænsefladen. REST API-understøttelse af SQL-operatoren er ikke tilgængelig endnu.

Relateret indhold

  • Last updated on