Notatka
Dostęp do tej strony wymaga autoryzacji. Może spróbować zalogować się lub zmienić katalogi.
Dostęp do tej strony wymaga autoryzacji. Możesz spróbować zmienić katalogi.
W tym artykule przedstawiono sposób tworzenia domyślnych i pochodnych strumieni zdarzeń usługi Microsoft Fabric. Strumień danych to dynamiczny i ciągły przepływ danych, który oferuje szereg możliwości natychmiastowego działania i analizy. Za pomocą strumienia danych można skonfigurować alerty w czasie rzeczywistym, przesyłać je do różnych typów magazynów danych i włączać model publikowania/subskrybowania, do którego wielu klientów może subskrybować.
Integracja funkcji centrum czasu rzeczywistego w strumieniach zdarzeń Fabric dodatkowo zwiększa te możliwości. Ta integracja umożliwia tworzenie wielu strumieni danych i zarządzanie nimi przy użyciu różnych operacji przetwarzania, które następnie można wyświetlić w centrum czasu rzeczywistego.
Pojęcia
Eventstream to element w obszarze roboczym Fabric, który umożliwia pozyskiwanie, przekształcanie i kierowanie strumieni danych do różnych miejsc docelowych w usłudze Fabric.
Strumień to ciągły i niezwiązany przepływ zdarzeń danych. Gdy zdarzenia danych napływają do strumieni zdarzeń Fabric, w strumieniach zdarzeń Fabric tworzy się strumień reprezentujący te zdarzenia danych. W strumieniach zdarzeń platformy Fabric są dwa rodzaje strumieni:
Strumień domyślny. Każdy element strumienia zdarzeń Fabric ma domyślny strumień, który jest automatycznie generowany po dodaniu źródła strumienia do strumienia zdarzeń. Reprezentuje nieprzetworzone zdarzenia pochodzące ze źródła przesyłania strumieniowego. Możesz przekształcić i skierować domyślny strumień do wielu lokalizacji docelowych w Fabric. Możesz wyświetlić strumień domyślny z centrum czasu rzeczywistego.
Strumień pochodny to wyspecjalizowany typ elementu docelowego w strumieniach zdarzeń Fabric, tworzony po dodaniu serii operacji na strumieniu, takich jak Filter lub Manage Fields. Strumień pochodny reprezentuje przekształcony domyślny strumień po przetwarzaniu strumienia. Możesz również kierować dane przesyłane strumieniowo w strumieniu pochodnym do wielu miejsc docelowych w usłudze Fabric. Po utworzeniu jest ona gotowa do dalszego użycia lub analizy przez innych użytkowników w organizacji za pośrednictwem centrum czasu rzeczywistego.
Tworzenie domyślnego strumienia
Po utworzeniu nowego strumienia zdarzeń można dodać źródło do strumienia zdarzeń, a domyślny strumień zostanie wygenerowany automatycznie. Poniższy przykład pokazuje, że domyślny strumień es-5-stream jest automatycznie generowany po dodaniu przykładowego źródła danych dotyczących rowerów do elementu Strumienie zdarzeń w usłudze Fabric.
Tworzenie strumienia pochodnego
Aby utworzyć nowy strumień pochodny, dodaj operację, taką jak Filtruj do strumienia zdarzeń. Następnie wybierz opcję Strumień .
Nadaj nazwę nowemu strumieniu i wybierz pozycję Publikuj, aby zatwierdzić zmiany.
Po zakończeniu możesz uzyskać dostęp do strumieni domyślnych i pochodnych w usłudze Real-Time hub w celu dalszego wykorzystania, na przykład do podglądu strumienia lub dodawania miejsc docelowych, do których ma być kierowany strumień.
Wstrzymywanie i wznawianie pochodnych strumieni
Teraz możesz wstrzymać i wznowić ruch z pochodzących strumieni. Zapewnia to większą elastyczność i kontrolę nad przepływem danych bez usuwania lub ponownego konfigurowania topologii strumienia zdarzeń.
Gdy strumień pochodny jest wstrzymany, Eventstream tymczasowo przestaje wysyłać dane do miejsca docelowego, zachowując wszystkie konfiguracje strumienia. Możesz wznowić ruch w dowolnym momencie, aby bezproblemowo kontynuować przetwarzanie zdarzeń.
Użyj tej funkcji, aby:
- Tymczasowo zatrzymaj przepływ danych na potrzeby konserwacji lub rozwiązywania problemów.
- Zmniejsz koszty pozyskiwania lub przetwarzania podczas testowania lub okresów niskiej aktywności.