Składniki strumieni zdarzeń

  • 10 min

Strumienie zdarzeń usługi Microsoft Fabric działają przez utworzenie potoku zdarzeń z wielu wewnętrznych i zewnętrznych źródeł do różnych miejsc docelowych. Można o tym myśleć jako przenośnik taśmowy, który przenosi dane z jednego miejsca do drugiego. Możesz również dodać pewne przekształcenia do danych po drodze, takie jak filtrowanie, agregowanie lub wzbogacanie.

Zrzut ekranu przedstawiający strumień zdarzeń.

Edytor wizualizacji strumienia zdarzeń umożliwia projektowanie potoku, przeciągając i upuszczając różne węzły, takie jak źródła, miejsca docelowe i przekształcenia. Możesz również zobaczyć dane zdarzenia przepływające przez potok w czasie rzeczywistym. Strumień zdarzeń usługi Microsoft Fabric automatycznie obsługuje skalowanie, niezawodność i zabezpieczenia strumienia zdarzeń. Nie musisz pisać żadnego kodu ani zarządzać żadną infrastrukturą, aby korzystać z usługi Microsoft Fabric Eventstream.

Główne składniki strumienia zdarzeń to:

  • Źródła: źródła to miejsce, z którego pochodzą dane zdarzenia. Jako typ źródła możesz wybrać usługę Azure Event Hubs, przykładowe dane lub aplikację niestandardową. Możesz również wybrać format danych i grupę odbiorców źródła.
  • Przekształcenia: możesz dodawać przekształcenia, które filtrują lub agregują dane przetwarzane ze strumienia. Przekształcenia obejmują typowe operacje danych, takie jak filtrowanie, łączenie, agregowanie i grupowanie, a także funkcje okien czasowych, które umożliwiają analizowanie zdarzeń danych w dyskretnych okresach.
  • Miejsca docelowe: miejsca docelowe to miejsce przechowywania przekształconych danych zdarzeń. Możesz na przykład przechowywać wyniki przetwarzania strumienia w tabeli w magazynie zdarzeń lub lakehouse albo przekierowywać dane do innego strumienia zdarzeń w celu dalszego przetwarzania lub do aktywatora w celu wyzwolenia akcji.

Możesz użyć kanwy edytowania strumienia zdarzeń, aby dodać źródła i miejsca docelowe oraz zarządzać nimi. Możesz również wyświetlić dane zdarzenia, sprawdzić szczegółowe informacje o danych i wyświetlić dzienniki dla każdego źródła lub miejsca docelowego.