Korzystanie z rejestru schematów platformy Azure w usłudze Event Hubs z platformy Apache Kafka i innych aplikacji

  • Artykuł

W wielu scenariuszach przesyłania strumieniowego i obsługi komunikatów zdarzenie lub ładunek komunikatów zawiera dane ustrukturyzowane. Formaty oparte na schematach, takie jak Apache Avro , są często używane do serializacji lub deserializacji takich danych strukturalnych.

Producent zdarzeń używa schematu do serializacji ładunku zdarzenia i publikowania go w brokerze zdarzeń, takim jak Event Hubs. Odbiorcy zdarzeń odczytują ładunek zdarzeń od brokera i deserializować go przy użyciu tego samego schematu. W związku z tym zarówno producenci, jak i konsumenci mogą zweryfikować integralność danych przy użyciu tego samego schematu.

Obraz przedstawiający producentów i konsumentów serializacji i deserializacji ładunku zdarzenia przy użyciu schematów z rejestru schematów.

Co to jest rejestr schematów platformy Azure?

Rejestr schematów platformy Azure to funkcja usługi Event Hubs, która udostępnia centralne repozytorium schematów dla aplikacji opartych na zdarzeniach i przesyłania komunikatów. Zapewnia elastyczność wymiany danych przez producentów i konsumentów bez konieczności zarządzania schematem i udostępniania go. Udostępnia również prostą strukturę ładu dla schematów wielokrotnego użytku i definiuje relację między schematami za pomocą konstrukcji grupowania (grup schematów).

Obraz przedstawiający producenta i konsumenta serializacji i deserializacji ładunku zdarzenia przy użyciu schematu z rejestru schematów.

W przypadku platform serializacji opartej na schemacie, takich jak Apache Avro, przenoszenie metadanych serializacji do udostępnionych schematów może również pomóc w zmniejszeniu obciążenia na komunikat. Jest to spowodowane tym, że każdy komunikat nie musi mieć metadanych (informacji o typie i nazwach pól), ponieważ jest to przypadek z oznaczonymi formatami, takimi jak JSON.

Uwaga

Funkcja nie jest dostępna w warstwie podstawowa .

Posiadanie schematów przechowywanych obok zdarzeń i wewnątrz infrastruktury zdarzeń zapewnia, że metadane wymagane do serializacji lub deserializacji są zawsze dostępne, a schematy nie mogą zostać zagubione.

Następne kroki