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

Jeśli chcesz połączyć własną aplikację za pomocą strumienia zdarzeń, możesz dodać niestandardowy punkt końcowy (tj. niestandardową aplikację w standardowej możliwości). Następnie możesz wysłać dane do strumienia zdarzeń z własnej aplikacji z punktem końcowym połączenia wyświetlanym jako niestandardowy punkt końcowy (tj. aplikacja niestandardowa w standardowej możliwości). W tym artykule przedstawiono sposób dodawania niestandardowego punktu końcowego (tj. niestandardowej aplikacji w standardowej możliwości) do strumienia zdarzeń.

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.

Wymagania wstępne

• Dostęp do obszaru roboczego Sieć szkieletowa Premium z uprawnieniami współautora lub wyższymi uprawnieniami.

Ważne

Ulepszone możliwości strumieni zdarzeń sieci Szkieletowej są obecnie dostępne w wersji zapoznawczej.

Uwaga

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

Dodawanie niestandardowych danych punktu końcowego jako źródła

Wykonaj następujące kroki, aby dodać niestandardowe źródło punktu końcowego:

1. Aby utworzyć nowy strumień zdarzeń, wybierz pozycję Eventstream na ekranie głównym . Upewnij się, że opcja Rozszerzone możliwości (wersja zapoznawcza) jest włączona.

   

2. 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 . Następnie wybierz pozycję Dodaj źródło na wstążce i wybierz pozycję Niestandardowy punkt końcowy.

   

3. Na ekranie Niestandardowy punkt końcowy wprowadź nazwę niestandardowego źródła w obszarze Nazwa źródła, a następnie wybierz pozycję Dodaj.

   

4. Po utworzeniu niestandardowego źródła punktu końcowego zobaczysz go dodany do strumienia zdarzeń na kanwie w trybie edycji. Aby zaimplementować nowo dodane niestandardowe dane źródła aplikacji, wybierz pozycję Publikuj.

   

Po wykonaniu tych kroków niestandardowe dane punktu końcowego będą dostępne dla wizualizacji w widoku na żywo.

Pobieranie parametry połączenia i przykładowego kodu

W okienku Szczegóły widoku na żywo można zobaczyć trzy kategorie: Podstawowa, Klucze i Przykładowy kod. Możesz również wybrać 3 karty protokołów: Centrum zdarzeń, AMQP i Kafka. Informacje o kluczach i przykładowym kodzie różnią się w zależności od protokołu.

Podstawowe pokazuje nazwę, opis, typ i stan niestandardowego punktu końcowego.

Klucze pokazują parametry połączenia dla niestandardowego punktu końcowego, który można skopiować i wkleić do aplikacji.

Parametry połączenia jest ciągiem zgodnym z centrum zdarzeń, którego można użyć w aplikacji do odbierania zdarzeń z tego strumienia zdarzeń. Format centrum zdarzeń jest domyślnym formatem parametry połączenia i jest zgodny z zestawem SDK usługi Azure Event Hubs. Możesz użyć tego formatu, aby nawiązać połączenie z strumieniami zdarzeń przy użyciu 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_xxxxxxxx

Przykładowy kod przedstawia przykładowy kod, do którego można odwołać się lub skopiować i wkleić do aplikacji, aby wypchnąć lub ściągnąć dane zdarzenia do lub z tego strumienia zdarzeń.

Inne niż centrum zdarzeń pozostałe dwie karty formatu protokołu, które można wybrać w okienku Szczegóły , to AMQP i Kafka.

• Format AMQP jest zgodny z protokołem AMQP 1.0, 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 strumieniami zdarzeń przy użyciu protokołu AMQP.

• Format platformy Kafka jest zgodny z protokołem Apache Kafka, 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ć tego formatu, aby nawiązać połączenie z strumieniami zdarzeń przy użyciu protokołu Kafka.

Możesz wybrać format protokołu odpowiadający potrzebom i preferencjom aplikacji. Wybierz te karty w okienku Szczegóły , aby uzyskać dostosowane klucze i przykładowy kod. Skopiuj i wklej parametry połączenia z sekcji Klucze do aplikacji. Zapoznaj się lub skopiuj i wklej podany przykładowy kod, aby 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 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ń.

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ń przy użyciu własnej aplikacji z punktem końcowym połączenia uwidoczniony w aplikacji niestandardowej. Wykonaj następujące kroki, aby dodać niestandardowe źródło aplikacji:

1. Wybierz pozycję Nowe źródło na wstążce lub "+" na kanwie edytora głównego, a następnie pozycję Aplikacja niestandardowa.

2. Wprowadź nazwę źródłową aplikacji niestandardowej i wybierz pozycję Dodaj.

   

3. Po pomyślnym utworzeniu niestandardowego źródła aplikacji można przełączyć i wyświetlić następujące informacje na karcie Szczegóły w dolnym okienku:

   

   • Podstawowe: przedstawia nazwę, opis, typ i stan aplikacji niestandardowej.
   • Klucze: pokazuje parametry połączenia dla aplikacji niestandardowej, którą można skopiować i wkleić do aplikacji.
   • Przykładowy kod: przedstawia przykładowy kod, do którego można odwołać się lub skopiować, aby wypchnąć dane zdarzenia do tego strumienia zdarzeń lub ściągnąć dane zdarzenia z tego strumienia zdarzeń.

   Dla każdej karty (przykładowy kod kluczy / podstawowych / ) można również przełączać trzy karty protokołów: Eventhub, AMQP i Kafka, aby uzyskać dostęp do różnych informacji o formatach protokołu:

   Parametry połączenia jest parametry połączenia zgodnym z centrum zdarzeń i można go użyć w aplikacji do odbierania zdarzeń z strumienia zdarzeń. Parametry połączenia ma wiele formatów protokołu, które można przełączać i wybierać na karcie Klucze. W poniższym przykładzie pokazano, jak wygląda parametry połączenia w formacie usługi Event Hubs:

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

   Format centrum zdarzeń jest domyślnym formatem parametry połączenia i jest zgodny z zestawem SDK usługi Azure Event Hubs. Możesz użyć tego formatu, aby nawiązać połączenie z strumieniem zdarzeń przy użyciu protokołu usługi Event Hubs.

   

   Pozostałe dwa formaty protokołów to AMQP i Kafka, które można wybrać, klikając odpowiednie karty na karcie Klucze.

   Format AMQP jest zgodny z protokołem AMQP 1.0, który jest standardowym protokołem obsługi komunikatów obsługującym 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.

   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ć tego formatu, aby nawiązać połączenie z strumieniem zdarzeń przy użyciu protokołu Kafka.

   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 podanego na karcie Przykładowy kod lub skopiować go, który pokazuje sposób wysyłania lub odbierania zdarzeń 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:

• Azure Event Hubs
• Azure IoT Hub
• Dane przykładowe