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

SubscribeOptions interface

包:

@azure/event-hubs

用于在 上配置 subscribe 方法的选项 EventHubConsumerClient。 例如： { maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }

属性

maxBatchSize	每批请求的事件数
maxWaitTimeInSeconds	在将数据传递给用户代码进行处理之前，等待建立请求的消息计数的最长时间。 如果未提供，则默认为 60 秒。
ownerLevel	要用作此订阅订阅分区的所有者级别。
prefetchCount	预先请求并排队的事件计数，而不考虑是否请求读取。
skipParsingBodyAsJson	用于在接收消息时禁止客户端在消息正文上运行 JSON.parse () 的选项。 如果消息是使用 AMQP 正文类型值或序列发送的，则不适用。 如果希望直接处理消息正文中存在的字节，而不是让客户端尝试分析该字节，请使用此选项。
startPosition	分区中的事件位置，如果未找到任何检查点，则从中开始接收事件。 如果要对每个分区使用不同的起始位置，请将分区 ID 的映射传递到位置。
tracingOptions	用于配置跟踪的选项。
trackLastEnqueuedEventProperties	指示使用者是否应请求有关其关联分区上最后一个排队事件的信息，并在接收事件时跟踪该信息。 跟踪有关分区最后一个排队事件的信息时，从事件中心服务接收的每个事件都将携带有关分区的元数据，否则不会。 这会导致少量额外的网络带宽消耗，在考虑使用事件中心客户端定期请求分区属性时，这通常是一个有利的权衡。

属性详细信息

maxBatchSize

每批请求的事件数

maxBatchSize?: number

属性值

number

maxWaitTimeInSeconds

在将数据传递给用户代码进行处理之前，等待建立请求的消息计数的最长时间。 如果未提供，则默认为 60 秒。

maxWaitTimeInSeconds?: number

属性值

number

ownerLevel

要用作此订阅订阅分区的所有者级别。

ownerLevel?: number

属性值

number

prefetchCount

预先请求并排队的事件计数，而不考虑是否请求读取。

prefetchCount?: number

属性值

number

skipParsingBodyAsJson

用于在接收消息时禁止客户端在消息正文上运行 JSON.parse () 的选项。 如果消息是使用 AMQP 正文类型值或序列发送的，则不适用。 如果希望直接处理消息正文中存在的字节，而不是让客户端尝试分析该字节，请使用此选项。

skipParsingBodyAsJson?: boolean

属性值

boolean

startPosition

分区中的事件位置，如果未找到任何检查点，则从中开始接收事件。 如果要对每个分区使用不同的起始位置，请将分区 ID 的映射传递到位置。

startPosition?: EventPosition | {[partitionId: string]: EventPosition}

属性值

EventPosition | {[partitionId: string]: EventPosition}

tracingOptions

用于配置跟踪的选项。

tracingOptions?: OperationTracingOptions

属性值

OperationTracingOptions

trackLastEnqueuedEventProperties

指示使用者是否应请求有关其关联分区上最后一个排队事件的信息，并在接收事件时跟踪该信息。

跟踪有关分区最后一个排队事件的信息时，从事件中心服务接收的每个事件都将携带有关分区的元数据，否则不会。 这会导致少量额外的网络带宽消耗，在考虑使用事件中心客户端定期请求分区属性时，这通常是一个有利的权衡。

trackLastEnqueuedEventProperties?: boolean

属性值

boolean