Udostępnij przez

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, korzystając z punktu końcowego połączenia dostępnego na niestandardowym punkcie końcowym lub niestandardowej aplikacji. 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 niestandardowe źródło aplikacji do strumienia zdarzeń w usłudze Microsoft Fabric.

Wymagania wstępne

  • Dostęp do środowiska roboczego, w którym znajduje się strumień zdarzeń. Obszar roboczy musi być w trybie pojemności Fabric lub w trybie wersji próbnej.

  • Współautor lub wyższe uprawnienia do edytowania strumienia zdarzeń i dodawania niestandardowego punktu końcowego jako źródła.

Uprawnienia do uwierzytelniania w usłudze Microsoft Entra

Jeśli chcesz użyć uwierzytelniania Microsoft Entra w celu połączenia aplikacji, potrzebujesz uprawnień członka lub wyższego poziomu.

Należy również upewnić się, że zarządzana tożsamość niestandardowego punktu końcowego posiada wymagane uprawnienia. Skonfiguruj ustawienia w portalu administracyjnym:

  1. W prawym górnym rogu wybierz pozycję Ustawienia (ikona koła zębatego).

  2. W obszarze Zarządzanie i analizy wybierz pozycję Portal administracyjny.

    Zrzut ekranu przedstawiający link do portalu administracyjnego w sekcji dotyczącej zarządzania i wglądu w ustawieniach.

  3. Aby przyznać jednostce usługi dostęp do interfejsów API Fabric do tworzenia obszarów roboczych, połączeń lub potoków wdrażania, aktywuj następujące ustawienie dzierżawy:

    1. Na stronie Ustawienia dzierżawy w sekcji Ustawienia dewelopera rozwiń opcję Główne jednostki usługi mogą używać Fabric API.
    2. Ustaw przełącznik na Włączone.
    3. W obszarze Zastosuj do wybierz pozycję Cała organizacja.
    4. Wybierz i zastosuj.

    Zrzut ekranu przedstawiający ustawienia dewelopera.

  4. Włącz tę opcję, aby uzyskać dostęp do pozostałych API (domyślnie włączone dla nowych klientów).

    1. Na stronie Ustawienia dzierżawy rozwiń opcję Zezwalaj jednostkom usługi na tworzenie i używanie profilów .
    2. Ustaw przełącznik na Włączone.
    3. W obszarze Zastosuj do wybierz pozycję Cała organizacja.
    4. Wybierz i zastosuj.

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

  1. 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.

    Zrzut ekranu przedstawiający opcję użycia niestandardowego punktu końcowego.

  2. 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.

    Zrzut ekranu przedstawiający okno dialogowe dodawania niestandardowego punktu końcowego.

  3. 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.

    Zrzut ekranu przedstawiający strumień zdarzeń w trybie edycji z wyróżnionym przyciskiem Publikuj.

Uwaga

Strumień zdarzeń może obsługiwać maksymalnie 11 połączonych źródeł i miejsc docelowych tylko wtedy, gdy używasz następujących typów:

  • Źródło: Niestandardowy punkt końcowy.
  • Miejsca docelowe: indywidualny punkt końcowy i serwer zdarzeń z bezpośrednim przyjmowaniem.

Wszelkie źródła lub miejsca docelowe, które nie są uwzględnione na powyższej liście, oraz miejsca docelowe niedodane do strumienia domyślnego, nie liczą się do tego limitu.

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

  1. 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.

    Zrzut ekranu przedstawiający opcję użycia niestandardowego punktu końcowego.

  2. Na stronie Dodawanie źródła wybierz pozycję Aktywujdla skojarzenia schematu, a następnie wybierz pozycję Dodaj.

    Zrzut ekranu przedstawiający niestandardowe źródło punktu końcowego z opcją kojarzenia schematów.

  3. W edytorze, aby skojarzyć z nowym schematem lub istniejącym schematem z rejestru schematów, wybierz pozycję Skojarz schemat zdarzeń na wstążce.

    Zrzut ekranu edytora strumienia zdarzeń z przyciskiem kojarzenia schematu zdarzeń wybranego na wstążce.

  4. Aby użyć istniejącego schematu, wybierz pozycję Wybierz z rejestru schematów zdarzeń, a następnie wykonaj następujące kroki:

    1. W oknie dialogowym Kojarzenie schematu zdarzeń wybierz schemat z rejestru schematów. Schemat danych zdarzenia zostanie wyświetlony w okienku po prawej stronie.

    2. Wybierz Wybierz, by skojarzyć schemat zdarzeń z niestandardowym punktem końcowym.

      Zrzut ekranu przedstawiający okno dialogowe kojarzenia schematu zdarzeń ze schematem wybranym z rejestru schematów.

    3. W edytorze strumienia zdarzeń wybierz płytkę strumienia zdarzeń. W dolnym okienku przejdź do karty Skojarzony schemat . Upewnij się, że schemat jest skojarzony z strumieniem zdarzeń.

      Zrzut ekranu edytora strumienia zdarzeń z wybranym strumieniem zdarzeń i z wyróżnioną kartą dla skojarzonego schematu.

  5. Użyj jednej z następujących opcji, aby utworzyć schemat:

    • Jeśli masz plik JSON schematu, wybierz pozycję Przekaż , aby przekazać plik. Aby uzyskać przykładowy plik, zobacz Pobieranie schematu zdarzeń.

      Zrzut ekranu pokazujący opcję przesyłania, aby utworzyć schemat.

    • Rozpocznij tworzenie schematu ręcznie, wybierając pozycję Dodaj wiersz. Dla każdego wiersza wybierz typ pola, wybierz nazwę pola i opcjonalnie wprowadź opis.

      Zrzut ekranu przedstawiający ręczny sposób tworzenia schematu.

    • Aby utworzyć schemat, wprowadzając kod JSON, wybierz opcję Edytor kodu . Jeśli komunikat Jeśli zdecydujesz się użyć edytora kodu do utworzenia schematu, pamiętaj, że nie będzie można przełączyć się z powrotem do konstruktora interfejsu użytkownika , wybierz pozycję Edytuj.

      Zrzut ekranu przedstawiający edytor kodu w celu utworzenia schematu.

      Wprowadź kod JSON w edytorze.

      Zrzut ekranu przedstawiający kod JSON w edytorze kodu w celu utworzenia schematu.

Uwaga

Strumień zdarzeń może obsługiwać maksymalnie 11 połączonych źródeł i miejsc docelowych tylko wtedy, gdy używasz następujących typów:

  • Źródło: Niestandardowy punkt końcowy.
  • Miejsca docelowe: niestandardowy punkt końcowy i centrum zdarzeń z bezpośrednim wprowadzaniem.

Wszystkie źródła lub miejsca docelowe, które nie zostały uwzględnione na powyższej liście, oraz miejsca docelowe, które nie są dołączone do strumienia domyślnego, nie są liczone w tym limicie.

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 dwie strony, które oferują szczegóły punktu końcowego z odpowiednim protokołem do łączenia:

  • Podstawowa wyświetla nazwę, typ i stan niestandardowego punktu końcowego.

    Zrzut ekranu przedstawiający podstawowe informacje w okienku Szczegóły widoku na żywo transmisji zdarzeń.

  • Uwierzytelnianie kluczem SAS zawiera informacje o kluczach połączenia. Udostępnia również link do przykładowego kodu z wbudowanymi kluczami, za pomocą którego można przesyłać zdarzenia do swojego strumienia zdarzeń. Informacje na tej stronie różnią się w zależności od protokołu.

Centrum zdarzeń

Karta Uwierzytelnianie klucza SAS dla protokołu Event Hub zawiera informacje o ciągu połączenia Event Hub. Informacje obejmują nazwę centrum zdarzeń, nazwę klucza dostępu współdzielonego, klucz podstawowy, klucz pomocniczy, łańcuch połączenia — klucz podstawowy i łańcuch 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 przycisk wyświetlania przykładowego kodu w okienku Szczegóły widoku na żywo transmisji strumieniowej zdarzeń.

AMQP

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

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 przycisk wyświetlania przykładowego kodu 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 przycisk przykładowego kodu Kafka w okienku Szczegóły widoku na żywo eventstream.

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 streamingu i konsumowania zdarzeń.

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ąć przykładowy widok kodu, wybierz pozycję Ukryj przykładowy kod.

Konfigurowanie miejsc docelowych strumienia zdarzeń do używania schematów

Obecnie w przypadku strumieni zdarzeń z włączonymi funkcjami rozszerzonymi obsługiwane są tylko eventhouse, punkt końcowy niestandardowy i pochodne strumienie docelowe. W tej sekcji przedstawiono sposób dodawania i konfigurowania punktu docelowego zarządzania zdarzeniami po włączeniu rozszerzonych funkcji, takich jak wsparcie dla schematów, dla strumienia zdarzeń.

Konfiguracja schematu dla niestandardowego adresu końcowego

  1. Wybierz pozycję Przekształć zdarzenia lub dodaj miejsce docelowe, a następnie wybierz pozycję CustomEndpoint.

  2. W okienku Niestandardowy punkt końcowy określ nazwę miejsca docelowego.

  3. W polu Schemat wejściowy wybierz schemat zdarzeń. W tym polu dokonujesz wyboru, gdy włączysz obsługę schematu dla strumienia zdarzeń.

Zrzut ekranu przedstawiający okienko służące do konfigurowania niestandardowego punktu końcowego.

Aby uzyskać szczegółowe instrukcje dotyczące konfigurowania niestandardowego miejsca docelowego punktu końcowego, zobacz Dodawanie niestandardowego punktu końcowego lub niestandardowego miejsca docelowego aplikacji do strumienia zdarzeń.

Skonfiguruj schematy dla destynacji Eventhouse

  1. Wybierz pozycję Przekształć zdarzenia lub dodaj miejsce docelowe, a następnie wybierz pozycję Eventhouse.

  2. W okienku Eventhouse skonfiguruj następujące ustawienia związane ze schematem:

    1. W polu Schemat wejściowy wybierz jeden lub więcej schematów z listy rozwijanej.

      Zrzut ekranu przedstawiający okienko konfiguracji eventhouse z wybranym schematem wejściowym.

      Uwaga

      W przypadku wybrania opcji Schemat dynamiczny za pomocą nagłówków podczas konfigurowania źródła usługi Event Hubs można skonfigurować wiele schematów dla źródła i zamapować je na różne właściwości i ich wartości.

    2. W polu Metoda tworzenia tabeli wybierz pozycję Pojedyncza tabela ze wszystkimi schematami połączonymi lub Oddzielnymi tabelamidla każdego schematu w zależności od wymagań.

      Zrzut ekranu przedstawiający panel konfiguracji eventhouse z metodami tworzenia tabel.

    3. W obszarze Zapisywanie danych za pomocą wybierz jedną z następujących opcji:

      • Tylko ładunek: Zapisz wyodrębnione dane ładunku do tabeli. Jeśli istnieje wiele schematów wejściowych, dane są wysyłane do wielu tabel.
      • Metadane i ładunek: zapisuj metadane i ładunki danych w jednej tabeli. Przykładowe kolumny obejmują source , , subjecttypei data.

      Zrzut ekranu przedstawiający okienko konfiguracji magazynu zdarzeń z opcjami zapisywania danych.

Aby uzyskać szczegółowe instrukcje dotyczące konfigurowania celu eventhouse, zobacz Dodawanie celu eventhouse do strumienia zdarzeń.

Powiązana zawartość

  • Last updated on