Przetwarzanie strumieni danych w strumieniach zdarzeń usługi Fabric

Strona Łączenie źródła danych, strona Źródła firmy Microsoft, strona zdarzeń sieci szkieletowej i strona zdarzeń platformy Azure w centrum czasu rzeczywistego umożliwia tworzenie strumieni dla obsługiwanych źródeł. Po utworzeniu tych strumieni można je przetwarzać, analizować i ustawiać na nich alerty. W tym artykule wyjaśniono, jak przetwarzać strumienie danych przy użyciu przekształceń obsługiwanych w strumieniach zdarzeń sieci Szkieletowej.

Otwieranie strumienia zdarzeń

W centrum czasu rzeczywistego podczas tworzenia strumieni w celu pobierania zdarzeń z obsługiwanych źródeł tworzony jest strumień zdarzeń. Możesz otworzyć nadrzędny strumień zdarzeń dla strumienia, korzystając z jednego z następujących sposobów:

• Dodawanie środowiska źródłowego :

  Na końcu tworzenia tego strumienia na stronie Przeglądanie i łączenie zostanie wyświetlony link Otwórz strumień zdarzeń, aby otworzyć strumień zdarzeń skojarzony ze strumieniem w edytorze.

• Strona Wszystkie strumienie danych:

  Przenieś wskaźnik myszy na strumień, którego element nadrzędny jest strumieniem zdarzeń, a następnie wybierz link Otwórz , wybierając pozycję ... (wielokropek), a następnie wybierz pozycję Otwórz strumień zdarzeń.

• Strona szczegółów :

  Na stronie Wszystkie strumienie danych wybierz strumień, którego element nadrzędny jest strumieniem zdarzeń, aby wyświetlić szczegóły strumienia. Na wstążce wybierz pozycję Otwórz strumień zdarzeń.

Dodawanie przekształceń do strumienia

Po otwarciu strumienia zdarzeń w edytorze można dodawać przekształcenia, takie jak Agregacja, Rozwijanie, Filtrowanie, Grupowanie według, Zarządzanie polami i Unii, aby przekształcić lub przetworzyć przesyłanie strumieniowe danych do sieci szkieletowej, a następnie wysłać dane wyjściowe z przekształceń do obsługiwanych miejsc docelowych. Aby uzyskać więcej informacji na temat przekształceń, zobacz Obsługiwane operacje przekształcania.

Powiązana zawartość

Po przetworzeniu danych w strumieniu można wysłać dane wyjściowe do miejsc docelowych obsługiwanych przez strumienie zdarzeń sieci szkieletowej.