SubscribeOptions interface
üzerinde EventHubConsumerClient
yöntemini yapılandırma subscribe
seçenekleri.
Örneğin, { maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }
Özellikler
max |
Toplu iş başına istenecek olay sayısı |
max |
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. |
owner |
Bu abonelik bölümlere abone olduğu için kullanılacak sahip düzeyi. |
prefetch |
İstekle istenen ve okuma istenip istenmediğine bakılmaksızın kuyruğa alınan olayların sayısı. |
skip |
İ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. |
start |
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. |
tracing |
İzlemeyi yapılandırma seçenekleri. |
track |
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
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