Odnajdywanie usługi Azure Event Hubs
Usługa Azure Event Hubs reprezentuje "drzwi wejściowe" dla potoku zdarzeń, często nazywanego ingestorem zdarzeń w architekturach rozwiązań. System zbierania zdarzeń to składnik lub usługa, która znajduje się między wydawcami zdarzeń, a ich odbiorcami. Jego rolą jest oddzielenie procesu tworzenia strumienia zdarzeń od użycia tych zdarzeń. Usługa Event Hubs udostępnia ujednoliconą platformę przesyłania strumieniowego z buforem przechowywana czasowego, co umożliwia uniezależnienie wydawców i odbiorców zdarzeń.
W poniższej tabeli przedstawiono najważniejsze funkcje usługi Azure Event Hubs:
| Funkcja | opis |
|---|---|
| W pełni zarządzana usługa PaaS | Event Hubs to w pełni zarządzana usługa PaaS (Platform-as-a-Service), która wymaga niewielkich nakładów na konfigurację i zarządzanie, dzięki czemu możesz skoncentrować się na swoich rozwiązaniach biznesowych. Usługa Event Hubs dla ekosystemów platformy Apache Kafka zapewnia środowisko platformy Kafka PaaS bez konieczności zarządzania, konfigurowania lub uruchamiania klastrów. |
| Przetwarzanie wsadowe i w czasie rzeczywistym | W usłudze Event Hubs jest używany partycjonowany model odbiorców, umożliwiający wielu aplikacjom jednoczesne przetwarzanie strumienia danych, podczas gdy Ty kontrolujesz szybkość przetwarzania. |
| Przechwyć dane zdarzeń | Przechwyć dane niemal w czasie rzeczywistym w usłudze Azure Blob Storage lub Azure Data Lake Storage na potrzeby długoterminowego przechowywania lub przetwarzania mikrosadowego. |
| Skalowalny | Opcje skalowania, takie jak automatyczne zwiększanie, skaluj liczbę jednostek przepływności, aby spełnić potrzeby użycia. |
| Zaawansowany ekosystem | Usługa Event Hubs dla ekosystemów platformy Apache Kafka umożliwia klientom i aplikacjom platformy Apache Kafka (w wersji 1.0 lub nowszej) komunikowanie się z usługą Event Hubs. Nie musisz konfigurować i konfigurować własnych klastrów platformy Kafka oraz zarządzać nimi. |
Kluczowe pojęcia
Usługa Event Hubs zawiera następujące kluczowe składniki:
- Klient usługi Event Hubs to podstawowy interfejs dla deweloperów korzystających z biblioteki klienta usługi Event Hubs. Istnieje kilka różnych klientów usługi Event Hubs, z których każda jest przeznaczona do określonego użycia usługi Event Hubs, takich jak publikowanie lub używanie zdarzeń.
- Producent usługi Event Hubs jest typem klienta, który służy jako źródło danych telemetrycznych, informacji diagnostycznych, dzienników użycia lub innych danych dziennika, w ramach rozwiązania urządzenia osadzonego, aplikacji urządzenia przenośnego, tytułu gry działającego na konsoli lub innym urządzeniu, niektórych klienta lub serwera opartego na rozwiązaniu biznesowym lub witrynie internetowej.
- Użytkownik usługi Event Hubs jest typem klienta, który odczytuje informacje z usługi Event Hubs i umożliwia jego przetwarzanie. Przetwarzanie może obejmować agregację, złożone obliczenia i filtrowanie. Przetwarzanie może również obejmować dystrybucję lub przechowywanie informacji w sposób pierwotny lub przekształcony. Użytkownicy usługi Event Hubs są często niezawodnymi i dużymi częściami infrastruktury platformy z wbudowanymi możliwościami analitycznymi, takimi jak Azure Stream Analytics, Apache Spark.
- Partycja to uporządkowana sekwencja zdarzeń przechowywanych w usłudze Event Hubs. Partycje to środek organizacji danych skojarzony z równoległością wymaganą przez odbiorców zdarzeń. Usługa Azure Event Hubs udostępnia przesyłanie strumieniowe komunikatów za pośrednictwem partycjonowanego wzorca konsumenta, w którym każdy odbiorca odczytuje tylko określony podzestaw lub partycję strumienia komunikatów. Po nadejściu nowszych zdarzeń są one dodawane na końcu tej sekwencji. Liczba partycji jest określana w momencie utworzenia usługi Event Hubs i nie można jej zmienić.
- Grupa odbiorców to widok całej usługi Event Hubs. Grupy odbiorców umożliwiają korzystanie z wielu aplikacji do każdego z nich ma oddzielny widok strumienia zdarzeń i odczytywanie strumienia niezależnie we własnym tempie i z własnej pozycji. W partycji na grupę odbiorców może znajdować się co najwyżej pięć równoczesnych czytników; zaleca się jednak, aby dla danej partycji i grupy odbiorców istniał tylko jeden aktywny użytkownik. Każdy aktywny czytelnik odbiera wszystkie zdarzenia z partycji; Jeśli na tej samej partycji znajduje się wiele czytników, otrzymają one zduplikowane zdarzenia.
- Odbiorniki zdarzeń: każda jednostka, która odczytuje dane zdarzeń z usługi Event Hubs. Wszyscy odbiorcy usługi Event Hubs łączą się za pomocą sesji protokołu AMQP 1.0. Usługa Event Hubs dostarcza zdarzenia za pośrednictwem sesji w miarę ich udostępniania. Wszyscy użytkownicy platformy Kafka nawiązują połączenia za pośrednictwem protokołu Kafka w wersji 1.0 lub nowszej.
- Jednostki przepływności lub jednostki przetwarzania: wstępnie pobrane jednostki pojemności kontrolujące pojemność przepływności usługi Event Hubs.
Na poniższym rysunku przedstawiono architekturę przetwarzania strumienia usługi Event Hubs:
