Klasyfikuj zdarzenia bez schematu w strumieniu zdarzeń uwzględniającym schemat (wersja zapoznawcza)

Niektóre strumienie zawierają nieschematyzowane zdarzenia o różnych kształtach. Na przykład strumień IoT może zawierać zdarzenia z różnych typów urządzeń. W strumieniu zdarzeń uwzględniającym schemat przepływ pracy Classifier umożliwia wskazanie pola klasyfikatora lub dyskryminatora, na przykład deviceType, przez wybranie go jako kolumny klasyfikatora. Eventstream wykorzystuje pole do rozróżniania i organizowania typów zdarzeń, utrzymując je w jednym potoku.

Important

Workflow Classifier jest częścią strumieni zdarzeń świadomych schematu, które są dostępne w trybie Podglądu. Informacje o wnioskowaniu na podstawie wielu schematów w istniejącym środowisku Eventstream można znaleźć tutaj: Ulepsz przetwarzanie zdarzeń za pomocą wnioskowania na podstawie wielu schematów.

Kiedy używać przepływu pracy Classifier

Korzystaj z workflow, gdy:

  • Wydarzenia są nieschematyczne.
  • Przez ten sam strumień przepływa wiele typów zdarzeń lub kształtów.
  • Zdarzenia zawierają pole, którego wartość identyfikuje typ zdarzenia, takie jak deviceType, eventType, lub entityType.
  • Chcesz przetwarzać typy zdarzeń w jednym potoku, zamiast tworzyć osobne strumienie zdarzeń.

Wymagania wstępne

Wybierz kolumnę klasyfikatora

Wybierz klasyfikator lub pole dyskryminatora, które:

  • Jest obecny na wydarzeniach, które chcesz sklasyfikować.
  • Ma stabilną wartość dla każdego typu zdarzenia.
  • Ma ograniczony zestaw wartościowych wartości.

Na przykład, rozważmy strumień IoT, który zawiera następujące zdarzenia:

{ "deviceType": "thermostat", "deviceId": "T-01", "temperature": 21.8 }
{ "deviceType": "camera", "deviceId": "C-07", "motionDetected": true }

Pole deviceType odróżnia zdarzenie termostatu od zdarzenia kamery.

Klasyfikacja konkurencji

  1. Otwórz Eventstream obsługujący schemat w trybie Edycja.

  2. Wybierz strumień zawierający zdarzenia bez schematów.

  3. W siatce podglądu danych wybierz Klasyfikuj zdarzenia nieschematyzowane.

    Otwiera się okno dialogowe Klasyfikowanie zdarzeń nieschematyzowanych.

    Zrzut ekranu siatki podglądu danych z przyciskiem Klasyfikuj nieschematyzowane zdarzenia.

  4. Wybierz kolumnę klasyfikatora, która identyfikuje każdy typ zdarzenia, na przykład .deviceType

    Możesz wybrać zagnieżdżone pole jako kolumnę klasyfikatora.

  5. Przeanalizuj typy zdarzeń zidentyfikowane na podstawie wartości pól.

  6. Wybierz Zapisz.

    Zrzut ekranu okna dialogowego „Klasyfikowanie nieschematyzowanych zdarzeń” z zaznaczoną opcją „deviceType”, czterema wykrytymi typami zdarzeń i przyciskiem „Zapisz”.

Po zapisaniu typy zdarzeń klasyfikowanych pojawiają się jako opcje do wyboru w podglądzie danych. Wybierz każdy typ zdarzenia, aby zweryfikować jego wykryty kształt zdarzenia.

Zrzut ekranu podglądu danych z czterema typami zdarzeń sklasyfikowanych wymienionymi w panelu typu Event.

Zachowanie klasyfikatora

  • Jeśli brakuje kolumny klasyfikatora lub jej wartość to null, zdarzenie pozostaje bez typu i nadal przechodzi przez Eventstream.
  • Gdy pojawi się nowa wartość klasyfikatora, Eventstream automatycznie dodaje nowy sklasyfikowany typ zdarzenia.
  • Wybierz pole z ograniczonym zbiorem wartościowych wartości. Pole o wysokiej kardynalności, takie jak unikalny identyfikator, może tworzyć zbyt wiele typów zdarzeń i utrudniać zarządzanie strumieniem zdarzeń.

Eksploruj i przetwarzaj tajne zdarzenia

Użyj przeprojektowanego podglądu danych, aby sprawdzić ładunek, nagłówki i metadane dla każdego sklasyfikowanego typu zdarzenia. Możesz także pobrać wybrane wydarzenia jako JSON. Aby uzyskać więcej informacji, zobacz Podgląd danych w strumieniu Eventstream uwzględniającym schemat (Podgląd).

Zaktualizowani operatorzy i miejsca docelowe mogą przetwarzać zdarzenia tajne razem ze schematycznymi i nietypowanymi zdarzeniami. Nie musisz tworzyć osobnych potoków dla każdego typu zdarzenia.