Udostępnij przez


Przetwarzanie danych zdarzeń przy użyciu edytora przetwarzania zdarzeń

Edytor przetwarzania zdarzeń to środowisko bez kodu, w którym przeciągasz elementy do projektowania logiki przetwarzania danych zdarzeń. W tym artykule opisano sposób projektowania logiki przetwarzania za pomocą edytora.

Uwaga

Rozszerzone możliwości są domyślnie włączone podczas tworzenia strumieni zdarzeń. Jeśli masz strumienie zdarzeń utworzone za pośrednictwem standardowych możliwości, te strumienie zdarzeń będą nadal działać. Nadal możesz edytować i używać ich jak zwykle. Zalecamy utworzenie nowego strumienia zdarzeń w celu zastąpienia standardowych strumieni zdarzeń, dzięki czemu można korzystać z dodatkowych możliwości i korzyści z rozszerzonych strumieni zdarzeń.

Wymagania wstępne

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

Projektowanie przetwarzania zdarzeń przy użyciu edytora

Aby wykonać operacje przetwarzania na strumieniach danych przy użyciu edytora bez kodu, wykonaj następujące kroki:

  1. Wybierz pozycję Edytuj na wstążce, jeśli nie jesteś jeszcze w trybie edycji . Upewnij się, że węzeł nadrzędny dla połączonych operacji ma schemat.

    Zrzut ekranu przedstawiający edytor przetwarzania zdarzeń w trybie edycji.

  2. Aby wstawić operator przetwarzania zdarzeń między węzłem strumienia a miejscem docelowym w trybie edycji , można użyć jednej z następujących dwóch metod:

    • Wstaw operator bezpośrednio z linii połączenia. Zatrzymaj wskaźnik myszy na linii połączenia, a następnie wybierz przycisk +. Pojawia się menu rozwijane na linii połączenia i można z tego menu wybrać operatora.

      Zrzut ekranu przedstawiający wybór przycisku z plusem na linii połączeniowej.

    • Wstaw operator z menu wstążki lub kanwy:

      1. Na wstążce możesz wybrać operator z menu Przekształć zdarzenia .

        Zrzut ekranu przedstawiający wybór operatora Zarządzaj polami na wstążce.

        Alternatywnie możesz najechać wskaźnikiem myszy na jeden z węzłów, a następnie wybrać + przycisk, jeśli linia połączenia została usunięta. W obszarze tuż przy węźle pojawi się menu rozwijane, z którego można wybrać operatora.

        Zrzut ekranu przedstawiający przycisk plus na linii połączenia.

      2. Po wstawieniu operatora należy ponownie połączyć te węzły. Umieść kursor na lewej krawędzi węzła strumienia, a następnie przeciągnij zielony okrąg, aby połączyć go z węzłem operatora Zarządzanie polami . Wykonaj ten sam proces, aby połączyć węzeł operatora Zarządzaj polami z miejscem docelowym.

        Zrzut ekranu przedstawiający sposób łączenia węzła strumienia z węzłem operatora.

  3. Wybierz węzeł Operator Zarządzaj polami. W okienku Zarządzanie konfiguracjami pól wybierz pola, których chcesz użyć do danych wyjściowych. Jeśli chcesz dodać wszystkie pola, wybierz pozycję Dodaj wszystkie pola.

    Możesz również dodać nowe pole przy użyciu wbudowanych funkcji w celu agregowania danych z nadrzędnego strumienia. Obecnie obsługiwane funkcje wbudowane to funkcje ciągów, funkcje daty i godziny oraz funkcje matematyczne. Aby je znaleźć, wyszukaj wbudowane.

    Zrzut ekranu przedstawiający sposób wybierania pól dla danych wyjściowych.

  4. Po skonfigurowaniu operatora Zarządzanie polami wybierz pozycję Odśwież , aby zweryfikować wynik testu generowany przez ten operator.

    Zrzut ekranu przedstawiający odświeżaną stronę.

  5. Jeśli występują błędy konfiguracji, są one wyświetlane na karcie Błędy tworzenia w dolnym okienku.

    Zrzut ekranu przedstawiający kartę błędów autorstwa.

  6. Jeśli wynik testu wygląda poprawnie, wybierz pozycję Publikuj , aby zapisać logikę przetwarzania zdarzeń i wrócić do widoku na żywo .

    Zrzut ekranu przedstawiający przycisk Publikuj na wstążce.

  7. Po wykonaniu powyższych kroków możesz wizualizować, jak rozpoczyna się przesyłanie i przetwarzanie danych w strumieniu zdarzeń w widoku Live.

    Zrzut ekranu przedstawiający widok na żywo.

Przekształcanie danych przy użyciu edytora

Edytor przetwarzania zdarzeń (kanwa w trybie edycji ) umożliwia przekształcanie danych w różne miejsca docelowe. Wprowadź Tryb Edytowania, aby projektować operacje przetwarzania strumieniowego dla Twoich strumieni danych.

Zrzut ekranu przedstawiający edytor przetwarzania zdarzeń dla strumienia zdarzeń z rozszerzonymi możliwościami.

Tryb edycji obejmuje kanwę i dolne okienko, w którym można:

  • Skompiluj logikę przekształcania danych zdarzeń, przeciągając.
  • Wyświetl podgląd wyniku testu w każdym z węzłów przetwarzania od początku do końca.
  • Odnajdź wszelkie błędy tworzenia w węzłach przetwarzania.

Układ edytora

Edytor przetwarzania zdarzeń składa się z trzech sekcji ponumerowanych na poniższej ilustracji.

Zrzut ekranu przedstawiający układ edytora przetwarzania zdarzeń dla strumienia zdarzeń z rozszerzonymi możliwościami.

  1. W okienku zawierającym menu wstążki i kanwę projektujesz logikę przekształcania danych, wybierając operator (z menu Przekształć zdarzenia ) i łącząc strumień i węzły docelowe za pośrednictwem nowo utworzonego węzła operatora. Możesz przeciągać linie łączące lub wybierać i usuwać połączenia.

  2. W okienku edytowania po prawej stronie skonfigurujesz wybrany węzeł lub wyświetlisz nazwę strumienia.

  3. W dolnym okienku wyświetlisz podgląd wyniku testu w wybranym węźle przy użyciu karty Wynik testu . Karta Błędy tworzenia zawiera wszystkie niekompletne lub nieprawidłowe konfiguracje w węzłach operacji.

Obsługiwane typy węzłów i przykłady

Poniżej przedstawiono typy docelowe, które obsługują dodawanie operatorów przed pozyskiwaniem:

  • Lakehouse
  • Eventhouse (przetwarzanie zdarzeń przed wprowadzaniem)
  • Strumień pochodny
  • Aktywator

Uwaga

W przypadku miejsc docelowych, które nie obsługują dodawania operatora pozyskiwania wstępnego, możesz najpierw dodać strumień pochodny jako dane wyjściowe operatora. Następnie dołącz zamierzone miejsce docelowe do tego wynikowego strumienia.

Zrzut ekranu przedstawiający układ edytora przetwarzania zdarzeń z filtrem, który wysyła dane wyjściowe do nieobsługiwanego miejsca docelowego.