SubscribeOptions interface

Paket:

@azure/event-hubs

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

Özellikler

maxBatchSize	Toplu iş başına istenecek 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 maksimum süre. Sağlanmazsa varsayılan olarak 60 saniye olur.
ownerLevel	Bu abonelik bölümlere abone olduğu için kullanılacak sahip düzeyi.
prefetchCount	İstekle istenen ve okuma istenip 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 doğrudan ileti gövdesinde bulunan baytlarla ç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, konuma bölüm kimliği eşlemesi 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 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, aksi takdirde bölümle ilgili olmayan meta verileri taşır. Bu, Event Hub istemcisini kullanarak bölüm özelliklerine yönelik isteklerin düzenli aralıklarla yapılmasına karşı genel olarak olumlu bir dengeleme olan az miktarda ek ağ bant genişliği tüketimine neden olur.

Özellik Ayrıntıları

maxBatchSize

Toplu iş başına istenecek 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 maksimum süre. Sağlanmazsa varsayılan olarak 60 saniye olur.

maxWaitTimeInSeconds?: number

Özellik Değeri

number

ownerLevel

Bu abonelik bölümlere abone olduğu için kullanılacak sahip düzeyi.

ownerLevel?: number

Özellik Değeri

number

prefetchCount

İstekle istenen ve okuma istenip 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 doğrudan ileti gövdesinde bulunan baytlarla ç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, konuma bölüm kimliği eşlemesi 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 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, aksi takdirde bölümle ilgili olmayan meta verileri taşır. Bu, Event Hub istemcisini kullanarak bölüm özelliklerine yönelik isteklerin düzenli aralıklarla yapılmasına karşı genel olarak olumlu bir dengeleme olan az miktarda ek ağ bant genişliği tüketimine neden olur.

trackLastEnqueuedEventProperties?: boolean

Özellik Değeri

boolean