Dodawanie źródła zdarzeń i zarządzanie nim w strumieniu zdarzeń
Po utworzeniu strumienia zdarzeń można połączyć je z różnymi źródłami danych i miejscami docelowymi.
Uwaga
Jeśli chcesz użyć rozszerzonych możliwości dostępnych w wersji zapoznawczej, wybierz pozycję Rozszerzone możliwości u góry. W przeciwnym razie wybierz pozycję Standardowe możliwości. Aby uzyskać informacje o rozszerzonych możliwościach dostępnych w wersji zapoznawczej, zobacz Wprowadzenie do strumieni zdarzeń usługi Fabric.
Po utworzeniu strumienia zdarzeń można połączyć go z różnymi źródłami danych i miejscami docelowymi.
Strumień zdarzeń nie tylko umożliwia przesyłanie strumieniowe danych ze źródeł firmy Microsoft, ale także obsługuje pozyskiwanie z platform innych firm, takich jak Google Cloud i Amazon Kinesis, z nowymi łącznikami obsługi komunikatów. Ta rozszerzona funkcja zapewnia bezproblemową integrację zewnętrznych strumieni danych z siecią szkieletową, zapewniając większą elastyczność i umożliwiając uzyskiwanie szczegółowych informacji w czasie rzeczywistym z wielu źródeł.
W tym artykule przedstawiono źródła zdarzeń, które można dodać do strumienia zdarzeń z rozszerzonymi możliwościami w wersji zapoznawczej.
Ważne
Ulepszone możliwości strumieni zdarzeń sieci Szkieletowej są obecnie dostępne w wersji zapoznawczej.
Wymagania wstępne
- Dostęp do obszaru roboczego Premium sieci szkieletowej dla obszaru roboczego z uprawnieniami współautora lub wyższymi uprawnieniami.
- Wymagania wstępne specyficzne dla każdego źródła, które są udokumentowane w następujących artykułach specyficznych dla źródła.
Obsługiwane źródła
Strumienie zdarzeń sieci szkieletowej z rozszerzonymi możliwościami obsługują następujące źródła. Każdy artykuł zawiera szczegółowe informacje i instrukcje dotyczące dodawania określonych źródeł.
| Źródła | opis |
|---|---|
| Azure Event Hubs | Jeśli masz centrum zdarzeń platformy Azure, możesz pozyskiwać dane centrum zdarzeń do usługi Microsoft Fabric przy użyciu strumienia zdarzeń. |
| Azure IoT Hub | Jeśli masz centrum Azure IoT, możesz pozyskiwać dane IoT do usługi Microsoft Fabric przy użyciu usługi Eventstream. |
| Przechwytywanie zmian danych w usłudze Azure SQL Database (CDC) | Łącznik źródłowy usługi Azure SQL Database CDC umożliwia przechwycenie migawki bieżących danych w bazie danych Azure SQL Database. Następnie łącznik monitoruje i rejestruje wszelkie przyszłe zmiany na poziomie wiersza w tych danych. |
| CdC bazy danych PostgreSQL | Łącznik źródłowy przechwytywania zmian danych bazy danych PostgreSQL (CDC) umożliwia przechwycenie migawki bieżących danych w bazie danych PostgreSQL. Następnie łącznik monitoruje i rejestruje wszelkie przyszłe zmiany na poziomie wiersza w tych danych. |
| Usługa CDC bazy danych MySQL | Łącznik źródła przechwytywania zmian danych w usłudze Azure MySQL (CDC) umożliwia przechwycenie migawki bieżących danych w bazie danych usługi Azure Database for MySQL. Możesz określić tabele do monitorowania, a strumień zdarzeń rejestruje wszelkie przyszłe zmiany na poziomie wiersza w tabelach. |
| Azure Cosmos DB CDC | Łącznik źródła przechwytywania zmian danych (CDC) usługi Azure Cosmos DB dla strumieni zdarzeń usługi Microsoft Fabric umożliwia przechwycenie migawki bieżących danych w bazie danych usługi Azure Cosmos DB. Następnie łącznik monitoruje i rejestruje wszelkie przyszłe zmiany na poziomie wiersza w tych danych. |
| Google Cloud Pub/Sub | Google Pub/Sub to usługa obsługi komunikatów, która umożliwia publikowanie i subskrybowanie strumieni zdarzeń. Możesz dodać usługę Google Pub/Sub jako źródło do strumienia zdarzeń w celu przechwytywania, przekształcania i kierowania zdarzeń w czasie rzeczywistym do różnych miejsc docelowych w usłudze Fabric. |
| Strumienie danych Amazon Kinesis | Strumienie danych Amazon Kinesis to wysoce skalowalne, wysoce trwałe pozyskiwanie danych i usługa przetwarzania zoptymalizowana pod kątem danych przesyłanych strumieniowo. Integrując strumienie danych Amazon Kinesis jako źródło w strumieniu zdarzeń, można bezproblemowo przetwarzać strumienie danych w czasie rzeczywistym przed kierowaniem ich do wielu miejsc docelowych w sieci szkieletowej. |
| Confluent Cloud Kafka | Confluent Cloud Kafka to platforma przesyłania strumieniowego oferująca zaawansowane funkcje przesyłania strumieniowego i przetwarzania danych przy użyciu platformy Apache Kafka. Integrując platformę Confluent Cloud Kafka jako źródło w strumieniu zdarzeń, można bezproblemowo przetwarzać strumienie danych w czasie rzeczywistym przed kierowaniem ich do wielu miejsc docelowych w sieci szkieletowej. |
| Zdarzenia usługi Azure Blob Storage | Zdarzenia usługi Azure Blob Storage są wyzwalane, gdy klient tworzy, zastępuje lub usuwa obiekt blob. Łącznik umożliwia łączenie zdarzeń usługi Blob Storage z zdarzeniami sieci szkieletowej w centrum czasu rzeczywistego. Te zdarzenia można przekonwertować na ciągłe strumienie danych i przekształcić je przed kierowaniem ich do różnych miejsc docelowych w sieci szkieletowej. |
| Zdarzenia elementu obszaru roboczego sieci szkieletowej | Zdarzenia elementu obszaru roboczego sieci szkieletowej to odrębne zdarzenia sieci szkieletowej, które występują po wprowadzeniu zmian w obszarze roboczym sieci szkieletowej. Te zmiany obejmują tworzenie, aktualizowanie lub usuwanie elementu sieci szkieletowej. Strumienie zdarzeń sieci szkieletowej umożliwiają przechwytywanie tych zdarzeń obszaru roboczego sieci szkieletowej, przekształcanie ich i kierowanie ich do różnych miejsc docelowych w sieci szkieletowej w celu dalszej analizy. |
| Dane przykładowe | Możesz wybrać pozycję Rowery, Żółta taksówka lub Zdarzenia giełdowe jako przykładowe źródło danych, aby przetestować pozyskiwanie danych podczas konfigurowania strumienia zdarzeń. |
| Niestandardowy punkt końcowy (tj. aplikacja niestandardowa w standardowej możliwości) | Funkcja niestandardowego punktu końcowego umożliwia aplikacjom lub klientom platformy Kafka łączenie się z strumieniem zdarzeń przy użyciu parametry połączenia, co umożliwia płynne pozyskiwanie danych przesyłanych strumieniowo do usługi Eventstream. |
Uwaga
Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.
Powiązana zawartość
Wymagania wstępne
Przed rozpoczęciem należy spełnić następujące wymagania wstępne:
- Uzyskaj dostęp do obszaru roboczego w warstwie Premium z uprawnieniami współautora lub wyższymi uprawnieniami, w których znajduje się strumień zdarzeń.
- Aby dodać usługę Azure Event Hubs lub Azure IoT Hub jako źródło strumienia zdarzeń, musisz mieć odpowiednie uprawnienia dostępu do kluczy zasad. Muszą być one publicznie dostępne, a nie za zaporą lub zabezpieczone w sieci wirtualnej.
Obsługiwane źródła
Następujące źródła są obsługiwane przez strumienie zdarzeń sieci szkieletowej. Użyj linków w tabeli, aby przejść do artykułów, które zawierają więcej szczegółów na temat dodawania określonych źródeł.
| Źródła | opis |
|---|---|
| Azure Event Hubs | Jeśli masz centrum zdarzeń platformy Azure, możesz pozyskiwać dane centrum zdarzeń do usługi Microsoft Fabric przy użyciu strumienia zdarzeń. |
| Azure IoT Hub | Jeśli masz centrum Azure IoT, możesz pozyskiwać dane IoT do usługi Microsoft Fabric przy użyciu usługi Eventstream. |
| Dane przykładowe | Możesz wybrać pozycję Rowery, Żółta taksówka lub Zdarzenia giełdowe jako przykładowe źródło danych, aby przetestować pozyskiwanie danych podczas konfigurowania strumienia zdarzeń. |
| Aplikacja niestandardowa | Funkcja aplikacji niestandardowej umożliwia aplikacjom lub klientom platformy Kafka łączenie się z usługą Eventstream przy użyciu parametry połączenia, co umożliwia płynne pozyskiwanie danych przesyłanych strumieniowo do usługi Eventstream. |
Uwaga
Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.
Zarządzanie źródłem
Edytuj/usuń: możesz wybrać źródło strumienia zdarzeń, aby edytować lub usunąć za pośrednictwem okienka nawigacji lub kanwy. Po wybraniu pozycji Edytuj okienko edycji zostanie otwarte po prawej stronie edytora głównego.
Wygeneruj ponownie klucz dla aplikacji niestandardowej: jeśli chcesz ponownie wygenerować nowy klucz połączenia dla aplikacji, wybierz jedno z niestandardowych źródeł aplikacji na kanwie i wybierz pozycję Wygeneruj ponownie , aby uzyskać nowy klucz połączenia.
Powiązana zawartość
Opinia
Dostępne już wkrótce: W 2024 r. będziemy stopniowo wycofywać zgłoszenia z serwisu GitHub jako mechanizm przesyłania opinii na temat zawartości i zastępować go nowym systemem opinii. Aby uzyskać więcej informacji, sprawdź: https://aka.ms/ContentUserFeedback.
Prześlij i wyświetl opinię dla