Udostępnij przez

Przetwarzanie zdarzeń przy użyciu operatora SQL (wersja zapoznawcza)

Operator SQL (wersja zapoznawcza), nazywany również edytorem kodu SQL, to nowa funkcja przekształcania danych w strumieniach zdarzeń usługi Microsoft Fabric. Operatory SQL zapewniają środowisko edytowania kodu, w którym można łatwo zdefiniować własną niestandardową logikę przekształcania danych przy użyciu prostych wyrażeń SQL. W tym artykule opisano sposób używania operatora SQL do przekształcania danych w strumieniu zdarzeń.

Note

Nazwy artefaktów strumienia zdarzeń, które zawierają podkreślenie (_) lub kropkę (.) nie są zgodne z operatorami SQL. Aby uzyskać najlepsze wrażenia, utwórz nowy strumień zdarzeń bez używania podkreśleń lub kropek w nazwie artefaktu.

Prerequisites

  • Dostęp do obszaru roboczego w trybie licencji pojemności Fabric lub w trybie licencji próbnej z uprawnieniami współautora lub wyższymi.

Dodawanie operatora SQL do strumienia zdarzeń

Aby wykonać operacje przetwarzania strumieniowego na strumieniach danych przy użyciu operatora SQL, dodaj operator SQL do strumienia zdarzeń, korzystając z następujących instrukcji:

  1. Utwórz nowy strumień zdarzeń. Następnie dodaj do niego operator SQL przy użyciu jednej z następujących opcji:

    • Na wstążce wybierz pozycję Przekształć zdarzenia, a następnie wybierz pozycję SQL.

      Zrzut ekranu przedstawiający wybór operatora SQL w menu przekształcania zdarzeń.

    • Na kanwie wybierz pozycję Przekształć zdarzenia lub dodaj miejsce docelowe, a następnie wybierz pozycję Sql Code.

      Zrzut ekranu przedstawiający wybór operatora SQL na liście do przekształcania zdarzeń na kanwie.

  2. Dodano nowy węzeł SQL do strumienia zdarzeń. Wybierz ikonę ołówka, aby kontynuować konfigurowanie operatora SQL.

    Zrzut ekranu przedstawiający wybór ikony ołówka w węźle operatora SQL.

  3. W okienku Kod SQL określ unikatową nazwę węzła operatora SQL w strumieniu zdarzeń.

  4. Edytuj zapytanie w obszarze zapytania lub wybierz pozycję Edytuj zapytanie , aby wprowadzić widok edytora kodu pełnoekranowego.

    Zrzut ekranu przedstawiający pole wprowadzania nazwy operacji i przycisk edytowania zapytania w okienku Kod SQL.

  5. Tryb edytora kodu pełnoekranowego zawiera okienko eksploratora danych wejściowych/wyjściowych po lewej stronie. Sekcja edytora kodu jest dostosowywna, dzięki czemu można zmienić jej rozmiar zgodnie z preferencjami. Sekcja podglądu u dołu umożliwia wyświetlanie zarówno danych wejściowych, jak i wyniku testu zapytania.

    Zrzut ekranu przedstawiający pełny edytor SQL.

  6. Wybierz tekst w sekcji Dane wyjściowe , a następnie wprowadź nazwę węzła docelowego. Operator SQL obsługuje wszystkie miejsca docelowe analizy Real-Time, w tym magazyn zdarzeń, jezioro, aktywację lub strumień.

    Zrzut ekranu przedstawiający obszar Dane wyjściowe z wybranym przyciskiem plus.

  7. Określ alias lub nazwę miejsca docelowego danych wyjściowych, w którym są zapisywane dane przetwarzane za pośrednictwem operatora SQL.

    Zrzut ekranu przedstawiający nazwę danych wyjściowych.

  8. Dodaj zapytanie SQL dotyczące wymaganej transformacji danych.

    Strumień zdarzeń jest oparty na usłudze Azure Stream Analytics i obsługuje tę samą semantykę języka zapytań Stream Analytics. Aby dowiedzieć się więcej na temat składni i użycia, zobacz Azure Stream Analytics i Eventstream Query Language Reference.

    Oto podstawowa struktura zapytań:

    SELECT 

    column1, column2, ... 

INTO 

    [output alias] 

FROM 

    [input alias]

    Ten przykład zapytania przedstawia wykrywanie wysokich temperatur w pomieszczeniu co 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

    W tym przykładzie zapytania pokazano wyrażenie CASE kategoryzujące 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. Na wstążce użyj polecenia Test query , aby zweryfikować logikę przekształcania. Wyniki zapytania testowego są wyświetlane na karcie Wynik testu .

    Zrzut ekranu przedstawiający wynik testu.

  10. Po zakończeniu testowania wybierz pozycję Zapisz na wstążce, aby wrócić do kanwy strumienia zdarzeń.

    Zrzut ekranu przedstawiający wstążkę zapytania, w tym polecenia do testowania zapytania i zapisywania.

  11. Jeśli w okienku Kod SQL jest włączony przycisk Zapisz , wybierz go, aby zapisać ustawienia.

    Zrzut ekranu przedstawiający okienko Kod SQL i przycisk Zapisz.

  12. Skonfiguruj miejsce docelowe.

    Zrzut ekranu przedstawiający ukończony strumień zdarzeń.

Limitations

  • Operator SQL został zaprojektowany tak, aby scentralizować całą logikę transformacji. W związku z tym nie można jej używać razem z innymi wbudowanymi operatorami w ramach tej samej ścieżki przetwarzania. Łączenie wielu operatorów SQL w jednej ścieżce również nie jest obsługiwane. Ponadto operator SQL może wysyłać dane wyjściowe tylko do węzła docelowego w topologii.

  • Obecnie tworzenie topologii strumienia zdarzeń jest obsługiwane tylko za pośrednictwem interfejsu użytkownika. Obsługa interfejsu API REST dla operatora SQL nie jest jeszcze dostępna.

Treści powiązane

  • Last updated on