Dodawanie niestandardowego punktu końcowego lub niestandardowego źródła aplikacji do strumienia zdarzeń
Jeśli chcesz połączyć własną aplikację z strumieniem zdarzeń, możesz dodać niestandardowy punkt końcowy lub aplikację niestandardową jako źródło. Następnie możesz wysyłać zdarzenia w czasie rzeczywistym do strumienia zdarzeń z własnej aplikacji przy użyciu punktu końcowego połączenia uwidocznionego w niestandardowym punkcie końcowym lub aplikacji niestandardowej. Ponadto przy użyciu protokołu Apache Kafka dostępnego jako opcji niestandardowych punktów końcowych lub aplikacji niestandardowych można wysyłać zdarzenia w czasie rzeczywistym przy użyciu protokołu Apache Kafka.
W tym artykule pokazano, jak dodać niestandardowe źródło punktu końcowego lub niestandardowe źródło aplikacji do strumieni zdarzeń w strumieniach zdarzeń usługi Microsoft Fabric.
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ę Możliwości standardowe. Aby uzyskać informacje o rozszerzonych możliwościach dostępnych w wersji zapoznawczej, zobacz Wprowadzenie do strumieni zdarzeń usługi Fabric.
Wymagania wstępne
Przed rozpoczęciem musisz uzyskać dostęp do obszaru roboczego Premium usługi Fabric z uprawnieniami współautora lub wyższymi uprawnieniami.
Uwaga
Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.
Dodawanie niestandardowych danych punktu końcowego jako źródła
Utwórz nowy strumień zdarzeń:
Na stronie głównej wybierz pozycję Eventstream.
W oknie dialogowym Nowy strumień zdarzeń wprowadź nazwę, upewnij się, że wybrano opcję Rozszerzone możliwości (wersja zapoznawcza), a następnie wybierz pozycję Utwórz.
Aby dodać niestandardowe źródło punktu końcowego, na stronie wprowadzenie wybierz pozycję Użyj niestandardowego punktu końcowego.
Lub jeśli masz już opublikowany strumień zdarzeń i chcesz dodać niestandardowe dane punktu końcowego jako źródło, przełącz się do trybu edycji. Na wstążce wybierz pozycję Dodaj źródłowy punkt>końcowy niestandardowy.
W oknie dialogowym Niestandardowy punkt końcowy wprowadź nazwę niestandardowego źródła w obszarze Nazwa źródła, a następnie wybierz pozycję Dodaj.
Po utworzeniu niestandardowego źródła punktu końcowego zostanie ono dodane do strumienia zdarzeń na kanwie w trybie edycji. Aby zaimplementować nowo dodane dane ze źródła aplikacji niestandardowej, wybierz pozycję Publikuj.
Pobieranie szczegółów punktu końcowego w okienku Szczegóły w celu wysyłania zdarzeń
Po utworzeniu niestandardowego źródła punktu końcowego jego dane są dostępne do wizualizacji w widoku na żywo.
Okienko Szczegóły zawiera trzy karty protokołu: Centrum zdarzeń, AMQP i Kafka. Każda karta protokołu ma trzy strony: Podstawowe, Klucze i Przykładowy kod. Te strony oferują szczegóły punktu końcowego z odpowiednim protokołem do nawiązywania połączenia.
W warstwie Podstawowa wyświetlana jest nazwa, typ i stan niestandardowego punktu końcowego.
Klucze zawierają informacje o kluczach połączenia. Przykładowy kod zawiera przykładowy kod z osadzonymi kluczami, którego można użyć do przesyłania strumieniowego zdarzeń do strumienia zdarzeń. Informacje na tych stronach różnią się w zależności od protokołu.
Centrum zdarzeń
Strona Klucze na karcie Centrum zdarzeń zawiera informacje dotyczące parametry połączenia centrum zdarzeń. Informacje obejmują nazwę centrum zdarzeń, nazwę klucza dostępu współdzielonego, klucz podstawowy i parametry połączenia — klucz podstawowy.
Format centrum zdarzeń jest domyślny dla parametry połączenia i współdziała z zestawem SDK usługi Azure Event Hubs. Ten format umożliwia nawiązywanie połączenia z strumieniem zdarzeń za pośrednictwem protokołu usługi Event Hubs.
W poniższym przykładzie pokazano, jak wygląda parametry połączenia w formacie centrum zdarzeń:
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx
Strona Przykładowy kod na karcie Centrum zdarzeń zawiera gotowy do użycia kod zawierający wymagane informacje o kluczach połączenia w centrum zdarzeń. Wystarczy skopiować i wkleić go do aplikacji do użycia.
Kafka
Format platformy Kafka jest zgodny z protokołem Apache Kafka, który jest popularną rozproszoną platformą przesyłania strumieniowego, która obsługuje przetwarzanie danych o wysokiej przepływności i małych opóźnieniach. Możesz użyć informacji o kluczach i przykładowym kodzie dla formatu protokołu Kafka, aby nawiązać połączenie ze strumieniem zdarzeń i przesyłać strumieniowo zdarzenia.
Przykładowa strona kodu na karcie Kafka zawiera gotowy kod, w tym niezbędne klucze połączenia w formacie platformy Kafka. Wystarczy skopiować go do użycia.
AMQP
Format AMQP jest zgodny z protokołem AMQP 1.0, który jest standardowym protokołem obsługi komunikatów, który obsługuje współdziałanie między różnymi platformami i językami. Możesz użyć tego formatu, aby nawiązać połączenie z strumieniem zdarzeń przy użyciu protokołu AMQP.
Przykładowa strona kodu na karcie AMQP zawiera gotowy do użycia kod z informacjami o kluczu połączenia w formacie AMQP.
Możesz wybrać format protokołu odpowiadający potrzebom i preferencjom aplikacji, a następnie skopiować i wkleić parametry połączenia do aplikacji. Możesz również odwołać się do przykładowego kodu lub skopiować go na stronie Przykładowy kod , który pokazuje, jak wysyłać lub odbierać zdarzenia przy użyciu różnych protokołów.
Powiązana zawartość
Aby dowiedzieć się, jak dodać inne źródła do strumienia zdarzeń, zobacz następujące artykuły:
- Strumienie danych Amazon Kinesis
- Zdarzenia usługi Azure Blob Storage
- Azure Cosmos DB
- Azure Event Hubs
- Azure IoT Hub
- Przechwytywanie zmian danych w usłudze Azure SQL Database (CDC)
- Confluent Kafka
- Zdarzenie obszaru roboczego sieci szkieletowej
- Google Cloud Pub/Sub
- Usługa CDC bazy danych MySQL
- CdC bazy danych PostgreSQL
- Dane przykładowe
Wymagania wstępne
Przed rozpoczęciem musisz uzyskać dostęp do obszaru roboczego w warstwie Premium z uprawnieniami współautora lub wyższymi uprawnieniami, w których znajduje się strumień zdarzeń.
Uwaga
Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.
Dodawanie aplikacji niestandardowej jako źródła
Jeśli chcesz połączyć własną aplikację z strumieniem zdarzeń, możesz dodać niestandardowe źródło aplikacji. Następnie wyślij dane do strumienia zdarzeń z własnej aplikacji przy użyciu punktu końcowego połączenia uwidocznionego w aplikacji niestandardowej.
Aby dodać niestandardowe źródło aplikacji:
Wybierz pozycję Nowe źródło na wstążce lub znak plus (+) na kanwie edytora głównego, a następnie wybierz pozycję Aplikacja niestandardowa.
W okienku Aplikacja niestandardowa wprowadź nazwę źródłową aplikacji niestandardowej, a następnie wybierz pozycję Dodaj.
Pobieranie szczegółów punktu końcowego w okienku Szczegóły w celu wysyłania zdarzeń
Po pomyślnym utworzeniu aplikacji niestandardowej jako źródła możesz wyświetlić informacje w okienku Szczegóły .
Okienko Szczegóły zawiera trzy karty protokołu: Centrum zdarzeń, AMQP i Kafka. Każda karta protokołu ma trzy strony: Podstawowe, Klucze i Przykładowy kod. Te strony oferują szczegóły punktu końcowego z odpowiednim protokołem do nawiązywania połączenia.
W warstwie Podstawowa wyświetlana jest nazwa, typ i stan aplikacji niestandardowej.
Klucze zawierają informacje o kluczach połączenia. Przykładowy kod zawiera przykładowy kod z osadzonymi kluczami, którego można użyć do przesyłania strumieniowego zdarzeń do strumienia zdarzeń. Informacje na tych stronach różnią się w zależności od protokołu.
Centrum zdarzeń
Strona Klucze na karcie Centrum zdarzeń zawiera informacje dotyczące parametry połączenia centrum zdarzeń. Informacje obejmują nazwę centrum zdarzeń, nazwę klucza dostępu współdzielonego, klucz podstawowy i parametry połączenia — klucz podstawowy.
Format centrum zdarzeń jest domyślny dla parametry połączenia i współdziała z zestawem SDK usługi Azure Event Hubs. Ten format umożliwia nawiązywanie połączenia z strumieniem zdarzeń za pośrednictwem protokołu usługi Event Hubs.
W poniższym przykładzie pokazano, jak wygląda parametry połączenia w formacie centrum zdarzeń:
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx
Strona Przykładowy kod na karcie Centrum zdarzeń zawiera gotowy do użycia kod zawierający wymagane informacje o kluczach połączenia w centrum zdarzeń. Wystarczy skopiować i wkleić go do aplikacji do użycia.
Kafka
Format platformy Kafka jest zgodny z protokołem Apache Kafka, który jest popularną rozproszoną platformą przesyłania strumieniowego, która obsługuje przetwarzanie danych o wysokiej przepływności i małych opóźnieniach. Możesz użyć informacji o kluczach i przykładowym kodzie dla formatu protokołu Kafka, aby nawiązać połączenie ze strumieniem zdarzeń i przesyłać strumieniowo zdarzenia.
Przykładowa strona kodu na karcie Kafka zawiera gotowy kod, w tym niezbędne klucze połączenia w formacie platformy Kafka. Wystarczy skopiować go do użycia.
AMQP
Format AMQP jest zgodny z protokołem AMQP 1.0, który jest standardowym protokołem obsługi komunikatów, który obsługuje współdziałanie między różnymi platformami i językami. Możesz użyć tego formatu, aby nawiązać połączenie z strumieniem zdarzeń przy użyciu protokołu AMQP.
Przykładowa strona kodu na karcie AMQP zawiera gotowy do użycia kod z informacjami o kluczu połączenia w formacie AMQP.
Możesz wybrać format protokołu odpowiadający potrzebom i preferencjom aplikacji, a następnie skopiować i wkleić parametry połączenia do aplikacji. Możesz również odwołać się do przykładowego kodu lub skopiować go na stronie Przykładowy kod , który pokazuje, jak wysyłać lub odbierać zdarzenia przy użyciu różnych protokołów.
Powiązana zawartość
Aby dowiedzieć się, jak dodać inne źródła do strumienia zdarzeń, zobacz następujące artykuły: