Źródła i miejsca docelowe strumienia zdarzeń
Najprostsze strumienie zdarzeń przechwytują dane w czasie rzeczywistym ze źródła i ładują przechwycone dane do miejsca docelowego.
Źródła strumienia zdarzeń
Źródła zdarzeń w usłudze Fabric w centrum czasu rzeczywistego mogą obejmować (między innymi):
- Azure Event Hub: Usługa Azure Event Hubs to źródło, które umożliwia pobieranie danych zdarzeń z centrum zdarzeń platformy Azure. Możesz określić format danych i grupę odbiorców centrum zdarzeń platformy Azure. Możesz również utworzyć połączenie w chmurze z centrum zdarzeń platformy Azure przy użyciu odpowiedniego poziomu uwierzytelniania i prywatności.
- Azure IoT Hub: usługa SaaS używana do łączenia i monitorowania milionów zasobów IoT oraz zarządzania nimi przy użyciu środowiska bez kodu.
- Przechwytywanie zmian danych w usłudze Azure SQL Database (CDC): proces oprogramowania, który identyfikuje i śledzi zmiany danych w bazie danych, umożliwiając przenoszenie danych w czasie rzeczywistym lub niemal w czasie rzeczywistym.
- CdC bazy danych PostgreSQL: łącznik CDC bazy danych PostgreSQL (przechwytywanie zmian danych) dla strumieni zdarzeń usługi Microsoft Fabric przechwytuje bieżącą migawkę i śledzi przyszłe zmiany w bazie danych PostgreSQL, umożliwiając przetwarzanie i analizowanie tych danych w czasie rzeczywistym w sieci szkieletowej.
- CdC bazy danych MySQL: Łącznik źródła cdC usługi Azure MySQL Database dla strumieni zdarzeń usługi Microsoft Fabric przechwytuje migawkę bazy danych MySQL i śledzi zmiany tabeli, umożliwiając przetwarzanie i analizę tych danych w czasie rzeczywistym w sieci szkieletowej.
- Azure Cosmos DB CDC: łącznik cdC usługi Azure Cosmos DB dla strumieni zdarzeń usługi Microsoft Fabric przechwytuje i śledzi zmiany danych w czasie rzeczywistym w usłudze Cosmos DB na potrzeby analizy i przetwarzania w sieci szkieletowej.
- Google Cloud Pub/Sub: usługa obsługi komunikatów do wymiany danych zdarzeń między aplikacjami i usługami.
- Strumienie danych Amazon Kinesis: zbieranie, przetwarzanie i analizowanie danych przesyłanych strumieniowo w czasie rzeczywistym.
- Confluent Cloud Kafka: w pełni zarządzana usługa oparta na platformie Apache Kafka do przetwarzania strumieniowego.
- Zdarzenia obszaru roboczego sieci szkieletowej: Zdarzenia obszaru roboczego sieci szkieletowej są wyzwalane przez zmiany w obszarze roboczym sieci szkieletowej, takie jak tworzenie, aktualizowanie lub usuwanie elementów. Strumienie zdarzeń sieci szkieletowej umożliwiają przechwytywanie, przekształcanie i kierowanie tych zdarzeń w celu szczegółowej analizy i monitorowania w sieci szkieletowej. Ta integracja zapewnia większą elastyczność śledzenia i zrozumienia działań obszaru roboczego.
- Zdarzenia usługi Azure Blob Storage: Zdarzenia usługi Azure Blob Storage to wyzwalacze systemowe dla akcji, takich jak tworzenie, zastępowanie lub usuwanie obiektu blob. Strumienie zdarzeń usługi Microsoft Fabric łączą te akcje ze zdarzeniami sieci szkieletowej, co umożliwia przetwarzanie zdarzeń usługi Blob Storage jako ciągłych strumieni danych na potrzeby routingu i analizy w sieci szkieletowej. Jedną z unikatowych cech zdarzeń usługi Azure Blob Storage jest ich obsługa zdarzeń przesyłanych strumieniowo lub bez transmisji strumieniowej.
- Niestandardowy punkt końcowy: możesz użyć interfejsu API REST lub zestawów SDK udostępnianych przez usługę Microsoft Fabric, aby wysyłać dane zdarzeń z aplikacji niestandardowej do strumienia zdarzeń. Możesz również określić format danych i grupę odbiorców aplikacji niestandardowej.
- Przykładowe dane: przykładowe dane to źródło, które umożliwia korzystanie z wbudowanych przykładowych danych dostarczonych przez usługę Microsoft Fabric. Możesz wybrać spośród różnych przykładowych zestawów danych, takich jak IoT, Retail lub Finance. Możesz również dostosować częstotliwość i czas trwania generowania przykładowych danych.
Napiwek
Aby uzyskać więcej informacji na temat obsługiwanych źródeł, zobacz Obsługiwane źródła dla centrum w czasie rzeczywistym sieci szkieletowej.
Miejsca docelowe strumienia zdarzeń
Strumienie zdarzeń usługi Microsoft Fabric obsługują również możliwość wysyłania danych do następujących miejsc docelowych w trybie rozszerzonym.
- Eventhouse: To miejsce docelowe oferuje możliwość lejkowania danych zdarzeń w czasie rzeczywistym do bazy danych KQL, umożliwiając korzystanie z język zapytań Kusto (KQL) na potrzeby przesłuchania i analizy danych. Przechowywanie danych w bazie danych KQL umożliwia lepsze zrozumienie danych zdarzeń oraz tworzenie kompleksowych raportów i pulpitów nawigacyjnych.
- Lakehouse: to miejsce docelowe umożliwia wstępne przetwarzanie zdarzeń w czasie rzeczywistym przed ich pozyskiwaniem do lakehouse. Zdarzenia są przekształcane w format usługi Delta Lake, a później przechowywane w określonych tabelach lakehouse, ułatwiając potrzeby magazynowania danych.
- Niestandardowy punkt końcowy: dzięki tej funkcji możesz bezproblemowo kierować ruch zdarzeń w czasie rzeczywistym do aplikacji na zamówienie. Umożliwia integrację zastrzeżonych aplikacji ze strumieniem zdarzeń, co umożliwia natychmiastowe użycie danych zdarzeń. Ta funkcja jest korzystna w przypadku przesyłania danych w czasie rzeczywistym do niezależnego systemu, który nie jest hostowany w usłudze Microsoft Fabric.
- Strumień pochodny: strumień pochodny jest wyspecjalizowanym miejscem docelowym utworzonym po zastosowaniu operacji strumienia, takich jak Filtrowanie lub Zarządzanie polami do strumienia zdarzeń. Reprezentuje zmieniony strumień domyślny po przetworzeniu, który można kierować do różnych miejsc docelowych w sieci szkieletowej i monitorowanych w centrum czasu rzeczywistego.
- Aktywacja sieci szkieletowej: to miejsce docelowe umożliwia używanie aktywatora sieci szkieletowej do wyzwalania automatycznych akcji na podstawie wartości w danych przesyłanych strumieniowo.
Napiwek
Aby uzyskać więcej informacji na temat obsługiwanych źródeł, zobacz Dodawanie miejsca docelowego i zarządzanie nim w strumieniu zdarzeń.
W tym samym czasie można dołączyć do wielu miejsc docelowych w strumieniu zdarzeń bez wpływu na siebie lub kolizji ze sobą.