Поделиться через


Использование Реестра схем Azure в Центрах событий из Apache Kafka и других приложений

Во многих сценариях, связанных с потоковой передачи событий и обменом сообщениями, полезные данные о событиях или сообщениях содержат структурированную информацию. Для сериализации и десериализации таких структурированных данных часто используются основанные на схеме форматы, такие как Apache Avro.

Производитель событий использует схему для сериализации полезных данных события и публикует их в брокере событий, например в Центрах событий. Потребители событий считывают полезные данные события от брокера и десериализируют их с помощью той же схемы. Таким образом, производители и получатели могут проверять целостность данных с помощью одной и той же схемы.

Изображение, на котором производители и потребители сериализуют и десериализируют полезные данные событий с помощью схем из реестра схем.

Что такое Реестр схем Azure?

Реестр схем Azure — это функция Центров событий, которая предоставляет центральный репозиторий для схем для управляемых событиями и ориентированных на обмен сообщениями приложений. Он обеспечивает гибкость работы приложений-производителей и приложений-получателей при обмене данными, избавляя от необходимости управлять схемой и позволяя совместно использовать ее в приложениях обоих типов. Реестр схем также предоставляет простую платформу управления для повторно используемых схем и определяет связь между схемами через конструкцию группировки (группы схем).

Изображение, показывающее, как производитель и потребитель сериализуют и десериализируют полезные данные события с помощью схемы из реестра схем.

При использовании платформ сериализации на основе схем, таких как Apache Avro, перемещение метаданных сериализации в общие схемы может также помочь сократить объем служебных данных для каждого сообщения. Это связано с тем, что каждое сообщение не должно содержать метаданные (сведения о типе и имена полей), как в случае с помеченными форматами, такими как JSON.

Примечание

Эта функция недоступна для уровня Базовый.

Наличие схем, хранящихся вместе с событиями и внутри инфраструктуры событий, гарантирует, что метаданные, необходимые для сериализации или десериализации, всегда будут доступны и схемы не могут быть перемещены.

Дальнейшие действия