SubscribeOptions interface

Paket:

@azure/event-hubs

subscribe EventHubConsumerClient yöntemini yapılandırma seçenekleri. Örneğin, { maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }

Özellikler

maxBatchSize	Toplu iş başına istekte bulunacak olay sayısı
maxWaitTimeInSeconds	verileri işlenmek üzere kullanıcı koduna geçirmeden önce istenen ileti sayısını oluşturmak için beklenmesi gereken en uzun süre. Sağlanmazsa varsayılan olarak 60 saniye olur.
ownerLevel	Bu abonelik bölümlere abone olarak kullanılacak sahip düzeyi.
prefetchCount	İstekle istenen ve okunup istenmediğine bakılmaksızın kuyruğa alınan olayların sayısı.
skipParsingBodyAsJson	İstemcinin, iletiyi alırken ileti gövdesinde JSON.parse() çalıştırmasını devre dışı bırakma seçeneği. İleti AMQP gövde türü değeri veya dizisiyle gönderildiyse geçerli değildir. İstemcinin bunu ayrıştırmaya çalışmasındansa ileti gövdesinde bulunan baytlarla doğrudan çalışmayı tercih ettiğinizde bu seçeneği kullanın.
startPosition	Hiçbir denetim noktası bulunamazsa, olayları almaya başlamak için bir bölümdeki olay konumu. Her bölüm için farklı başlangıç konumu kullanmak istiyorsanız, konumlandırmak için bölüm kimliğinin bir haritasını geçirin.
tracingOptions	İzlemeyi yapılandırma seçenekleri.
trackLastEnqueuedEventProperties	Tüketicinin ilişkili bölümünde en son sıraya alınan olayla ilgili bilgi isteyip istememesi gerektiğini ve olaylar alınırken bu bilgileri izlemesi gerekip gerekmediğini gösterir. Bölümün en son sıraya alınan olayı hakkındaki bilgiler izlendiğinde, Event Hubs hizmetinden alınan her olay, bölümün aksi takdirde taşıyacağı meta verileri taşır. Bu, Olay Hub'ı istemcisini kullanarak bölüm özellikleri için düzenli aralıklarla istekte bulunmaya karşı genel olarak uygun bir dengeleme olan az miktarda ek ağ bant genişliği tüketimine neden olur.

Özellik Ayrıntıları

maxBatchSize

Toplu iş başına istekte bulunacak olay sayısı

maxBatchSize?: number

Özellik Değeri

number

maxWaitTimeInSeconds

verileri işlenmek üzere kullanıcı koduna geçirmeden önce istenen ileti sayısını oluşturmak için beklenmesi gereken en uzun süre. Sağlanmazsa varsayılan olarak 60 saniye olur.

maxWaitTimeInSeconds?: number

Özellik Değeri

number

ownerLevel

Bu abonelik bölümlere abone olarak kullanılacak sahip düzeyi.

ownerLevel?: number

Özellik Değeri

number

prefetchCount

İstekle istenen ve okunup istenmediğine bakılmaksızın kuyruğa alınan olayların sayısı.

prefetchCount?: number

Özellik Değeri

number

skipParsingBodyAsJson

İstemcinin, iletiyi alırken ileti gövdesinde JSON.parse() çalıştırmasını devre dışı bırakma seçeneği. İleti AMQP gövde türü değeri veya dizisiyle gönderildiyse geçerli değildir. İstemcinin bunu ayrıştırmaya çalışmasındansa ileti gövdesinde bulunan baytlarla doğrudan çalışmayı tercih ettiğinizde bu seçeneği kullanın.

skipParsingBodyAsJson?: boolean

Özellik Değeri

boolean

startPosition

Hiçbir denetim noktası bulunamazsa, olayları almaya başlamak için bir bölümdeki olay konumu. Her bölüm için farklı başlangıç konumu kullanmak istiyorsanız, konumlandırmak için bölüm kimliğinin bir haritasını geçirin.

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

Özellik Değeri

EventPosition | {[partitionId: string]: EventPosition}

tracingOptions

İzlemeyi yapılandırma seçenekleri.

tracingOptions?: OperationTracingOptions

Özellik Değeri

OperationTracingOptions

trackLastEnqueuedEventProperties

Tüketicinin ilişkili bölümünde en son sıraya alınan olayla ilgili bilgi isteyip istememesi gerektiğini ve olaylar alınırken bu bilgileri izlemesi gerekip gerekmediğini gösterir.

Bölümün en son sıraya alınan olayı hakkındaki bilgiler izlendiğinde, Event Hubs hizmetinden alınan her olay, bölümün aksi takdirde taşıyacağı meta verileri taşır. Bu, Olay Hub'ı istemcisini kullanarak bölüm özellikleri için düzenli aralıklarla istekte bulunmaya karşı genel olarak uygun bir dengeleme olan az miktarda ek ağ bant genişliği tüketimine neden olur.

trackLastEnqueuedEventProperties?: boolean

Özellik Değeri

boolean