Delen via

Gebeurtenissen verwerken met behulp van een SQL-operator (preview)

Een SQL-operator (preview), ook wel een SQL-code-editor genoemd, is een nieuwe mogelijkheid voor gegevenstransformatie in Microsoft Fabric-eventstreams. SQL-operators bieden een ervaring voor het bewerken van code, waar u eenvoudig uw eigen aangepaste logica voor gegevenstransformatie kunt definiëren met behulp van eenvoudige SQL-expressies. In dit artikel wordt beschreven hoe u een SQL-operator gebruikt voor gegevenstransformaties in een eventstream.

Note

Namen van eventstream-artefacten die een onderstrepingsteken (_) of punt (.) bevatten, zijn niet compatibel met SQL-operators. Maak voor de beste ervaring een nieuwe eventstream zonder onderstrepingstekens of punten in de naam van het artefact te gebruiken.

Prerequisites

  • Toegang tot een werkruimte in de fabric-capaciteitslicentiemodus of de proeflicentiemodus met inzender- of hogere machtigingen.

Een SQL-operator toevoegen aan een eventstream

Als u stroomverwerkingsbewerkingen wilt uitvoeren op uw gegevensstromen met behulp van een SQL-operator, voegt u een SQL-operator toe aan uw eventstream met behulp van de volgende instructies:

  1. Maak een nieuwe eventstream. Voeg er vervolgens een SQL-operator aan toe met behulp van een van de volgende opties:

    • Selecteer Transformeer gebeurtenissen op het lint en kies daarna SQL.

      Schermopname van de selectie van een SQL-operator in het menu voor het transformeren van gebeurtenissen.

    • Selecteer op het canvas transformatiegebeurtenissen of voeg doel toe en selecteer vervolgens SQL Code.

      Schermopname van de selectie van een SQL-operator in de lijst voor het transformeren van gebeurtenissen op het canvas.

  2. Er wordt een nieuw SQL-knooppunt toegevoegd aan uw eventstream. Selecteer het potloodpictogram om door te gaan met het instellen van de SQL-operator.

    Schermopname van de selectie van het potloodpictogram op het SQL-operatorknooppunt.

  3. Geef in het deelvenster SQL-code een unieke naam op voor het SQL-operatorknooppunt in de eventstream.

  4. Bewerk de query in het querygebied of selecteer Query bewerken om de code-editorweergave op volledig scherm in te voeren.

    Schermopname van het vak voor het invoeren van een bewerkingsnaam en de knop voor het bewerken van een query in het deelvenster SQL-code.

  5. De volledig scherm-editormodus bevat een deelvenster invoer-/uitvoerverkenner aan de linkerkant. De sectie code-editor is aanpasbaar, zodat u het formaat kunt wijzigen op basis van uw voorkeuren. Met de preview-sectie onderaan kunt u zowel uw invoergegevens als het testresultaat van uw query weergeven.

    Schermopname van de volledige SQL-editor.

  6. Selecteer de tekst in de sectie Uitvoer en voer vervolgens een naam in voor het doelknooppunt. De SQL-operator ondersteunt alle bestemmingen binnen Real-Time Intelligence, waaronder een eventhouse, lakehouse, activator of stream.

    Schermopname van het gebied Uitvoer met de plusknop geselecteerd.

  7. Geef een alias of naam op voor de uitvoerbestemming waarin de gegevens die via de SQL-operator worden verwerkt, worden geschreven.

    Schermopname die de naam voor een uitvoer toont.

  8. Sql-query toevoegen voor de vereiste gegevenstransformatie.

    Een eventstream is gebouwd op Azure Stream Analytics en ondersteunt dezelfde query-semantiek van de Stream Analytics-querytaal. Zie Azure Stream Analytics en Eventstream Query Language Reference voor meer informatie over de syntaxis en het gebruik.

    Dit is de basisquerystructuur:

    SELECT 

    column1, column2, ... 

INTO 

    [output alias] 

FROM 

    [input alias]

    In dit queryvoorbeeld ziet u de detectie van hoge temperaturen in een ruimte elke minuut:

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

    In dit queryvoorbeeld ziet u een CASE instructie voor het categoriseren van de temperatuur:

    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. Gebruik op het lint de opdracht Query testen om de transformatielogica te valideren. Testqueryresultaten worden weergegeven op het tabblad Testresultaten .

    Schermopname van een testresultaat.

  10. Wanneer u klaar bent met testen, selecteert u Opslaan op het lint om terug te gaan naar het eventstream-canvas.

    Schermopname van het lint voor een query, inclusief opdrachten voor het testen van de query en het opslaan van de query.

  11. Als de knop Opslaan is ingeschakeld in het deelvenster SQL-code, selecteert u deze om de instellingen op te slaan.

    Schermopname van het deelvenster SQL-code en de knop Opslaan.

  12. Configureer het doel.

    Schermopname van een voltooide gebeurtenisstream.

Limitations

  • De SQL-operator is ontworpen om al uw transformatielogica te centraliseren. Als gevolg hiervan kunt u deze niet naast andere ingebouwde operators binnen hetzelfde verwerkingspad gebruiken. Het koppelen van meerdere SQL-operators in één pad wordt ook niet ondersteund. Bovendien kan de SQL-operator uitvoergegevens verzenden naar alleen het doelknooppunt in de topologie.

  • Op dit moment wordt het ontwerpen van eventstream-topologieën alleen ondersteund via de gebruikersinterface. REST API-ondersteuning voor de SQL-operator is nog niet beschikbaar.

Verwante inhoud

  • Last updated on