Dodawanie niestandardowego punktu końcowego lub niestandardowego źródła aplikacji do strumienia zdarzeń

Artykuł
03/05/2025

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 protokół Apache Kafka, dostępny jako opcja dla niestandardowych punktów końcowych lub aplikacji, umożliwia wysyłanie zdarzeń w czasie rzeczywistym.

W tym artykule pokazano, jak dodać niestandardowe źródło punktu końcowego lub aplikacji do strumienia zdarzeń w Microsoft Fabric.

Uwaga

Rozszerzone możliwości są domyślnie włączone podczas tworzenia eventstreamów. Jeśli masz strumienie zdarzeń utworzone przy użyciu standardowych możliwości, te strumienie zdarzeń będą nadal działać. Nadal możesz edytować i używać ich jak zwykle. Zalecamy utworzenie nowego strumienia zdarzeń w celu zastąpienia standardowych strumieni zdarzeń, dzięki czemu można korzystać z dodatkowych możliwości i korzyści z rozszerzonych strumieni zdarzeń.

Wymagania wstępne

Dostęp do obszaru roboczego w trybie licencji pojemności Fabric lub w trybie licencji próbnej z uprawnieniami współautora lub wyższymi.
Jeśli nie masz strumienia zdarzeń, utwórz strumień zdarzeń.

Dodaj niestandardowe dane punktu końcowego jako źródło

Aby dodać niestandardowe źródło punktu końcowego, na stronie startowej wybierz opcję 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 Dodaj źródło>Niestandardowy punkt końcowy.
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.

Uwaga

Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.

Uzyskaj szczegóły punktu końcowego w okienku Szczegóły

Po utworzeniu niestandardowego źródła punktu końcowego jego dane są dostępne do wizualizacji w widoku na żywo.

Zrzut ekranu przedstawiający strumień zdarzeń 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, Uwierzytelnianie za pomocą klucza SAS. 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.

Strona uwierzytelniania SAS zawiera informacje o kluczach połączenia oraz link do przykładowego kodu z osadzonymi kluczami, które można wykorzystać do przesyłania strumieniowego zdarzeń do swojego strumienia zdarzeń. Informacje na stronie Klucze różnią się w zależności od protokołu.

Centrum zdarzeń

Strona SAS Key Authentication na karcie Centrum zdarzeń zawiera informacje dotyczące ciągu połączenia centrum zdarzeń. Informacje obejmują nazwę centrum zdarzeń, nazwę klucza dostępu współdzielonego, klucz podstawowy, klucz pomocniczy, parametry połączenia — klucz podstawowy, parametry połączenia — klucz pomocniczy.

Zrzut ekranu przedstawiający kluczowe informacje w okienku Szczegóły strumienia zdarzeń.

Format centrum zdarzeń jest domyślnym dla ciągu połączenia i współdziała z pakietem Azure Event Hubs SDK. 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 ciąg połączenia w formacie centrum zdarzeń.

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

Jeśli wybierzesz przycisk Pokaż przykładowy kod, zobaczysz gotowy do użycia kod Java zawierający wymagane informacje o kluczach połączenia w centrum zdarzeń. Skopiuj i wklej go do aplikacji do użycia.

Zrzut ekranu przedstawiający przykładowy kod w okienku Szczegóły widoku na żywo transmisji zdarzeń.

Advanced Message Queuing Protocol (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.

Zrzut ekranu przedstawiający klucze AMQP w okienku szczegółów widoku na żywo transmisji zdarzeń.

Po wybraniu przycisku Pokaż przykładowy kod zobaczysz gotowy do użycia kod Java z informacjami o kluczu połączenia w formacie AMQP.

Zrzut ekranu przedstawiający przykładowy kod protokołu AMQP w okienku Szczegóły widoku na żywo transmisji zdarzeń.

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. Aby połączyć się ze strumieniem zdarzeń i streamować wydarzenia, możesz użyć informacji o uwierzytelnianiu za pomocą klucza SAS dla formatu protokołu Kafka.

Zrzut ekranu przedstawiający klucze Kafka w okienku Szczegóły widoku na żywo strumienia zdarzeń.

Po wybraniu przycisku Pokaż przykładowy kod zobaczysz gotowy do użycia kod Java, w tym niezbędne klucze połączenia w formacie platformy Kafka. Skopiuj go do użycia.

Zrzut ekranu przedstawiający przykładowy kod platformy Kafka w okienku Szczegóły widoku na żywo transmisji zdarzeń.

Aby zapoznać się z jasnym przewodnikiem dotyczącym używania niestandardowego punktu końcowego z protokołem Kafka, zapoznaj się z tym samouczkiem. Zawiera szczegółowe instrukcje dotyczące przesyłania strumieniowego i używania zdarzeń przy użyciu niestandardowego punktu końcowego z protokołem Kafka.

Uwaga

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, który pokazuje, jak wysyłać lub odbierać zdarzenia przy użyciu różnych protokołów.

Aby zamknąć widok przykładowego kodu, wybierz pozycję Ukryj przykładowy kod.

Aby uzyskać listę obsługiwanych źródeł, zobacz Dodawanie źródła zdarzeń w strumieniu zdarzeń

Wymagania wstępne

Przed rozpoczęciem musisz uzyskać dostęp do obszaru roboczego z uprawnieniami współautora lub wyższymi, w którym 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, korzystając z punktu końcowego połączenia udostępnionego w niestandardowej aplikacji.

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.

Uzyskaj szczegóły punktu końcowego w okienku Szczegóły, aby wysyłać zdarzenia.

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.

Zrzut ekranu przedstawiający podstawowe informacje o aplikacji niestandardowej w panelu szczegółów strumienia zdarzeń.

Klucze zawierają informacje o kluczach połączenia. Przykładowy kod zawiera 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.