Udostępnij za pośrednictwem

AvroSerializer class

  • Odwołanie
Pakiet:
@azure/schema-registry-avro

Serializator Avro, który uzyskuje schematy z rejestru schematów i nie pakuje schematów do ładunków.

Konstruktory

AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)

Tworzy nowy serializator.

Metody

deserialize(MessageT, DeserializeOptions)

Deserializuje ładunek komunikatu przy użyciu identyfikatora schematu w polu typu zawartości, jeśli nie podano schematu.
serialize(unknown, string)

serializuje parametr wartości zgodnie ze schematem wejściowym i tworzy komunikat z danymi serializowanymi.

Szczegóły konstruktora

AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)

Tworzy nowy serializator.

new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)

Parametry

client
SchemaRegistry

Rejestr schematów, w którym schematy są rejestrowane i uzyskiwane. Zazwyczaj jest to wystąpienie SchemaRegistryClient.

options

AvroSerializerOptions<MessageT>

Szczegóły metody

deserialize(MessageT, DeserializeOptions)

Deserializuje ładunek komunikatu przy użyciu identyfikatora schematu w polu typu zawartości, jeśli nie podano schematu.

function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>

Parametry

message

MessageT

Komunikat z ładunkiem do deserializacji.

options
DeserializeOptions

Opcje dekodowania.

Zwraca

Promise<unknown>

Wartość deserializowana.

serialize(unknown, string)

serializuje parametr wartości zgodnie ze schematem wejściowym i tworzy komunikat z danymi serializowanymi.

function serialize(value: unknown, schema: string): Promise<MessageT>

Parametry

value

unknown

Wartość do serializacji.

schema

string

Schemat Avro do użycia.

Zwraca

Promise<MessageT>

Nowy komunikat o wartości serializowanej. Struktura komunikatu jest wyrejestrowana przez opcję fabryki komunikatów.