你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
AvroSerializer class
Avro 序列化程序从架构注册表获取架构,并且不会将架构打包到其有效负载中。
构造函数
Avro |
创建新的序列化程序。 |
方法
deserialize(MessageT, Deserialize |
如果未提供架构,则使用内容类型字段中的架构 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>
具有序列化值的新消息。 消息的结构由消息工厂选项控制。