SubscribeOptions interface
在 EventHubConsumerClient
上設定 subscribe
方法的選項。
例如,{ maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }
屬性
max |
每個批次要要求的事件數目 |
max |
將數據傳遞至使用者程式代碼進行處理之前,等待建立要求訊息計數的時間上限。 如果未提供,則預設為 60 秒。 |
owner |
要作為此訂用帳戶的擁有者層級訂閱數據分割。 |
prefetch |
要求和佇列的事件計數,而不考慮是否要求讀取。 |
skip |
在接收訊息時,停用用戶端在訊息本文上執行 JSON.parse() 的選項。 如果訊息是以AMQP 本文類型值或序列傳送,則不適用。 當您偏好直接處理訊息本文中存在的位元元組時,請使用此選項,而不是讓客戶端嘗試剖析它。 |
start |
如果找不到檢查點,則從分割區中開始接收事件的事件位置。 如果您想要針對每個分割區使用不同的起始位置,請將分割區標識碼的對應傳遞至位置。 |
tracing |
設定追蹤的選項。 |
track |
指出取用者是否應該在其相關聯的分割區上要求最後一個加入佇列事件的資訊,並追蹤接收事件時的資訊。 當追蹤分割區最後一個加入佇列事件的相關信息時,從事件中樞服務收到的每個事件都會攜帶有關該數據分割的元數據,否則不會。 這會導致少量額外的網路頻寬耗用量,這在考慮使用事件中樞用戶端定期提出分割區屬性的要求時,通常是有利的取捨。 |
屬性詳細資料
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
如果找不到檢查點,則從分割區中開始接收事件的事件位置。 如果您想要針對每個分割區使用不同的起始位置,請將分割區標識碼的對應傳遞至位置。
startPosition?: EventPosition | {[partitionId: string]: EventPosition}
屬性值
EventPosition | {[partitionId: string]: EventPosition}
tracingOptions
trackLastEnqueuedEventProperties
指出取用者是否應該在其相關聯的分割區上要求最後一個加入佇列事件的資訊,並追蹤接收事件時的資訊。
當追蹤分割區最後一個加入佇列事件的相關信息時,從事件中樞服務收到的每個事件都會攜帶有關該數據分割的元數據,否則不會。 這會導致少量額外的網路頻寬耗用量,這在考慮使用事件中樞用戶端定期提出分割區屬性的要求時,通常是有利的取捨。
trackLastEnqueuedEventProperties?: boolean
屬性值
boolean