你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

AvroSerializer class

Avro 序列化程序从架构注册表获取架构,并且不会将架构打包到其有效负载中。

构造函数

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

创建新的序列化程序。

方法

deserialize(MessageT, DeserializeOptions)

如果未提供架构,则使用内容类型字段中的架构 ID 反序列化消息的有效负载。

serialize(unknown, string)

根据输入架构序列化值参数,并使用序列化数据创建消息。

构造函数详细信息

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

创建新的序列化程序。

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

参数

client
SchemaRegistry

注册和获取架构的架构注册表。 通常,这是一个 SchemaRegistryClient 实例。

options

AvroSerializerOptions<MessageT>

方法详细信息

deserialize(MessageT, DeserializeOptions)

如果未提供架构,则使用内容类型字段中的架构 ID 反序列化消息的有效负载。

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

参数

message

MessageT

包含要反序列化的有效负载的消息。

options
DeserializeOptions

解码选项。

返回

Promise<unknown>

反序列化的值。

serialize(unknown, string)

根据输入架构序列化值参数,并使用序列化数据创建消息。

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

参数

value

unknown

要序列化的值。

schema

string

要使用的 Avro 架构。

返回

Promise<MessageT>

具有序列化值的新消息。 消息的结构由消息工厂选项控制。