Nawiązywanie połączenia z centrum zdarzeń z przepływów pracy w usłudze Azure Logic Apps

Dotyczy: Azure Logic Apps (Zużycie)

Łącznik usługi Azure Event Hubs ułatwia łączenie przepływów pracy aplikacji logiki z centrami zdarzeń na platformie Azure. Następnie przepływy pracy mogą monitorować zdarzenia wysyłane do centrum zdarzeń i zarządzać nimi. Na przykład przepływ pracy może sprawdzać, wysyłać i odbierać zdarzenia z centrum zdarzeń. Ten artykuł zawiera przewodnik wprowadzający do korzystania z łącznika usługi Azure Event Hubs, pokazując, jak nawiązać połączenie z centrum zdarzeń i dodać wyzwalacz lub akcję usługi Event Hubs do przepływu pracy.

Aby uzyskać więcej informacji na temat usługi Azure Event Hubs lub Azure Logic Apps, zobacz Co to jest usługa Azure Event Hubs lub Co to jest usługa Azure Logic Apps.

Dostępne operacje

Wszystkie operacje i inne informacje techniczne, takie jak właściwości, limity itd., przejrzyj stronę referencyjną łącznika usługi Event Hubs.

Wymagania wstępne

• Konto i subskrypcja platformy Azure. Jeśli nie masz subskrypcji platformy Azure, zarejestruj się w celu założenia bezpłatnego konta platformy Azure.

• Przestrzeń nazw i centrum zdarzeń usługi Event Hubs

• Przepływ pracy aplikacji logiki, w którym chcesz uzyskać dostęp do centrum zdarzeń

  Aby uruchomić przepływ pracy za pomocą wyzwalacza usługi Event Hubs, potrzebny jest pusty przepływ pracy. Jeśli dopiero zaczynasz korzystać z usługi Azure Logic Apps, wypróbuj ten przewodnik Szybki start, aby utworzyć przykładowy przepływ pracy aplikacji logiki Zużycie.

Sprawdzanie uprawnień i uzyskiwanie parametry połączenia

Aby upewnić się, że przepływ pracy może uzyskać dostęp do centrum zdarzeń, sprawdź swoje uprawnienia, a następnie uzyskaj parametry połączenia dla przestrzeni nazw centrum zdarzeń.

1. W witrynie Azure Portal przejdź do przestrzeni nazw usługi Event Hubs, a nie do określonego centrum zdarzeń.

2. W menu przestrzeni nazw w obszarze Ustawienia wybierz pozycję Zasady dostępu współdzielonego. W kolumnie Oświadczenia sprawdź, czy masz co najmniej uprawnienia Zarządzaj dla tej przestrzeni nazw.

   

3. Jeśli chcesz później ręcznie wprowadzić informacje o połączeniu, pobierz parametry połączenia dla przestrzeni nazw centrum zdarzeń.

   1. W kolumnie Zasady wybierz pozycję RootManageSharedAccessKey.

   2. Znajdź parametry połączenia klucza podstawowego. Skopiuj i zapisz parametry połączenia do późniejszego użycia.

      

      Napiwek

      Aby sprawdzić, czy parametry połączenia jest skojarzona z przestrzenią nazw usługi Event Hubs, czy z określonym centrum zdarzeń, upewnij się, że parametry połączenia nie ma parametruEntityPath. Jeśli znajdziesz ten parametr, parametry połączenia dotyczy określonej jednostki usługi Event Hubs i nie jest poprawnym ciągiem używanym z przepływem pracy.

Tworzenie połączenia centrum zdarzeń

Po dodaniu wyzwalacza lub akcji usługi Event Hubs po raz pierwszy zostanie wyświetlony monit o utworzenie połączenia z centrum zdarzeń.

1. Po wyświetleniu monitu wybierz jedną z następujących opcji:

   • Podaj następujące informacje o połączeniu:

     Właściwości	Wymagania	Wartość	Opis
     Nazwa połączenia	Tak	<nazwa połączenia>	Nazwa, która ma zostać utworzona dla połączenia
     Przestrzeń nazw usługi Event Hubs	Tak	<event-hubs-namespace>	Wybierz przestrzeń nazw usługi Event Hubs, której chcesz użyć.

   • Aby ręcznie wprowadzić wcześniej zapisane parametry połączenia, wybierz pozycję Ręcznie wprowadź informacje o połączeniu. Dowiedz się, jak znaleźć parametry połączenia.

2. Wybierz zasady usługi Event Hubs do użycia, jeśli nie zostały jeszcze wybrane, a następnie wybierz pozycję Utwórz.

   

3. Po utworzeniu połączenia przejdź do sekcji Dodawanie wyzwalacza usługi Event Hubs lub Dodaj akcję usługi Event Hubs.

Dodawanie wyzwalacza usługi Azure Event Hubs

W usłudze Azure Logic Apps każdy przepływ pracy musi rozpoczynać się od wyzwalacza, który jest uruchamiany po spełnieniu określonego warunku. Za każdym razem, gdy wyzwalacz jest uruchamiany, usługa Logic Apps tworzy wystąpienie przepływu pracy i uruchamia kroki w przepływie pracy.

W poniższych krokach opisano ogólny sposób dodawania wyzwalacza, na przykład Gdy zdarzenia są dostępne w centrum zdarzeń. W tym przykładzie pokazano, jak dodać wyzwalacz, który sprawdza nowe zdarzenia w centrum zdarzeń i uruchamia przebieg przepływu pracy, gdy istnieją nowe zdarzenia.

1. W Projektancie aplikacji usługi Logic Apps otwórz pusty przepływ pracy aplikacji logiki, jeśli nie został jeszcze otwarty.

2. W polu wyszukiwania operacji wprowadź .event hubs Z listy wyzwalaczy wybierz wyzwalacz o nazwie Gdy zdarzenia są dostępne w centrum zdarzeń.

   

3. Jeśli zostanie wyświetlony monit o utworzenie połączenia z centrum zdarzeń, podaj żądane informacje o połączeniu.

4. W wyzwalaczu podaj informacje o centrum zdarzeń, które chcesz monitorować, na przykład:

   Właściwości	Wymagania	opis
   Nazwa centrum zdarzeń	Tak	Nazwa centrum zdarzeń, które chcesz monitorować
   Typ zawartości	Nie.	Typ zawartości zdarzenia. Wartość domyślna to application/octet-stream.
   Nazwa grupy konsumentów	Nie.	Nazwa grupy odbiorców usługi Event Hubs do odczytywania zdarzeń. Jeśli nie zostanie określona, zostanie użyta domyślna grupa odbiorców.
   Maksymalna liczba zdarzeń	Nie.	Maksymalna liczba zdarzeń. Wyzwalacz zwraca między jedną a liczbą zdarzeń określonych przez tę właściwość.
   Interwał	Tak	Dodatnia liczba całkowita, która opisuje częstotliwość uruchamiania przepływu pracy na podstawie częstotliwości
   Częstotliwość	Tak	Jednostka czasu cyklu

   Aby uzyskać więcej właściwości, otwórz listę Dodaj nowy parametr . Wybranie parametru powoduje dodanie tej właściwości do wyzwalacza, na przykład:

   

   Więcej właściwości

   Właściwości	Wymagania	opis
   Schemat zawartości	Nie.	Schemat zawartości JSON dla zdarzeń do odczytu z centrum zdarzeń. Jeśli na przykład określisz schemat zawartości, możesz wyzwolić przepływ pracy tylko dla tych zdarzeń, które pasują do schematu.
   Minimalny klucz partycji	Nie.	Wprowadź minimalny identyfikator partycji do odczytania. Domyślnie wszystkie partycje są odczytywane.
   Maksymalny klucz partycji	Nie.	Wprowadź maksymalny identyfikator partycji do odczytania. Domyślnie wszystkie partycje są odczytywane.
   Strefa czasowa	Nie.	Ma zastosowanie tylko wtedy, gdy określisz godzinę rozpoczęcia, ponieważ ten wyzwalacz nie akceptuje przesunięcia UTC. Wybierz strefę czasową, którą chcesz zastosować. Aby uzyskać więcej informacji, zobacz Tworzenie i uruchamianie cyklicznych zadań i przepływów pracy za pomocą usługi Azure Logic Apps.
   Godzina rozpoczęcia	Nie.	Podaj godzinę rozpoczęcia w tym formacie: RRRR-MM-DDThh:mm:ss w przypadku wybrania strefy czasowej — lub — RRRR-MM-DDThh:mm:ssZ, jeśli nie wybierzesz strefy czasowej Aby uzyskać więcej informacji, zobacz Tworzenie i uruchamianie cyklicznych zadań i przepływów pracy za pomocą usługi Azure Logic Apps.

5. Gdy skończysz, na pasku narzędzi projektanta wybierz Zapisz.

6. Teraz kontynuuj dodawanie co najmniej jednej akcji, aby można było wykonywać inne zadania przy użyciu danych wyjściowych wyzwalacza.

   Aby na przykład filtrować zdarzenia na podstawie określonej wartości, takiej jak kategoria, można dodać warunek, aby akcja Wyślij zdarzenie wysyłała tylko zdarzenia spełniające warunek.

Wyzwalanie zachowania sondowania

Wszystkie wyzwalacze usługi Event Hubs są wyzwalaczami długiego sondowania. To zachowanie oznacza, że po wyzwoleniu wyzwalacza wyzwalacz przetwarza wszystkie zdarzenia i czeka 30 sekund, aż więcej zdarzeń pojawi się w centrum zdarzeń. Zgodnie z projektem, jeśli w ciągu 30 sekund nie pojawią się żadne zdarzenia, wyzwalacz zostanie pominięty. W przeciwnym razie wyzwalacz kontynuuje odczytywanie zdarzeń, dopóki centrum zdarzeń nie będzie puste. Następny ankieta wyzwalacza odbywa się na podstawie interwału cyklu ustawionego we właściwościach wyzwalacza.

Jeśli na przykład wyzwalacz jest skonfigurowany z czterema partycjami, to opóźnienie może potrwać do dwóch minut, zanim wyzwalacz zakończy sondowanie wszystkich partycji. Jeśli w tym opóźnieniu nie zostaną odebrane żadne zdarzenia, uruchomienie wyzwalacza zostanie pominięte. W przeciwnym razie wyzwalacz kontynuuje odczytywanie zdarzeń, dopóki centrum zdarzeń nie będzie puste. Następny ankieta wyzwalacza odbywa się na podstawie interwału cyklu określonego we właściwościach wyzwalacza.

Jeśli znasz określone partycje, w których są wyświetlane komunikaty, możesz zaktualizować wyzwalacz w celu odczytu zdarzeń tylko z tej lub tych partycji, ustawiając maksymalną i minimalną liczbę kluczy partycji wyzwalacza. Aby uzyskać więcej informacji, zapoznaj się z sekcją Dodawanie wyzwalacza usługi Event Hubs.

Wyzwalanie zachowania punktu kontrolnego

Gdy wyzwalacz usługi Event Hubs odczytuje zdarzenia z każdej partycji w centrum zdarzeń, wyzwalacz ma własny stan, aby zachować informacje o przesunięciu strumienia (pozycji zdarzenia w partycji) i partycjach, z których wyzwalacz odczytuje zdarzenia.

Za każdym razem, gdy przepływ pracy jest uruchamiany, wyzwalacz odczytuje zdarzenia z partycji, począwszy od przesunięcia strumienia przechowywanego przez stan wyzwalacza. W sposób okrężny wyzwalacz iteruje każdą partycję w centrum zdarzeń i odczytuje zdarzenia w kolejnych uruchomieniach wyzwalacza. Pojedyncze uruchomienie pobiera zdarzenia z pojedynczej partycji naraz.

Wyzwalacz nie korzysta z tej funkcji punktu kontrolnego w magazynie, co nie powoduje dodatkowych kosztów. Jednak kluczowym punktem jest to, że aktualizacja wyzwalacza usługi Event Hubs resetuje stan wyzwalacza, co może spowodować, że wyzwalacz odczytuje zdarzenia na początku strumienia.

Dodawanie akcji usługi Event Hubs

W usłudze Azure Logic Apps akcja jest zgodna z wyzwalaczem lub inną akcją i wykonuje jakąś operację w przepływie pracy. W poniższych krokach opisano ogólny sposób dodawania akcji, na przykład Wyślij zdarzenie. W tym przykładzie przepływ pracy rozpoczyna się od wyzwalacza usługi Event Hubs, który sprawdza nowe zdarzenia w centrum zdarzeń.

1. W Projektancie aplikacji logiki otwórz przepływ pracy aplikacji logiki, jeśli jeszcze nie jest otwarty.

2. W obszarze wyzwalacza lub innej akcji dodaj nowy krok.

   Aby dodać krok między istniejącymi krokami, przesuń wskaźnik myszy na strzałkę. Wybierz wyświetlony znak plus (+), a następnie wybierz pozycję Dodaj akcję.

3. W polu wyszukiwania operacji wprowadź .event hubs Z listy akcji wybierz akcję o nazwie Wyślij zdarzenie.

   

4. Jeśli zostanie wyświetlony monit o utworzenie połączenia z centrum zdarzeń, podaj żądane informacje o połączeniu.

5. W akcji podaj informacje o zdarzeniach, które chcesz wysłać.

   Właściwości	Wymagania	opis
   Nazwa centrum zdarzeń	Tak	Centrum zdarzeń, w którym chcesz wysłać zdarzenie
   Zawartość	Nie.	Zawartość zdarzenia, które chcesz wysłać
   Właściwości	Nie.	Właściwości i wartości aplikacji do wysłania
   Klucz partycji	Nie.	Identyfikator partycji dla miejsca wysyłania zdarzenia

   Aby uzyskać więcej właściwości, otwórz listę Dodaj nowy parametr . Wybranie parametru powoduje dodanie tej właściwości do akcji, na przykład:

   

   Możesz na przykład wysłać dane wyjściowe z wyzwalacza usługi Event Hubs do innego centrum zdarzeń:

   

6. Gdy skończysz, na pasku narzędzi projektanta wybierz Zapisz.

Informacje o łącznikach

Wszystkie operacje i inne informacje techniczne, takie jak właściwości, limity itd., przejrzyj stronę referencyjną łącznika usługi Event Hubs.

Następne kroki

• Łączniki zarządzane dla usługi Azure Logic Apps
• Wbudowane łączniki dla usługi Azure Logic Apps
• Co to są łączniki w usłudze Azure Logic Apps