SubscriptionEventHandlers interface
Olay Hub'ından olay almak için yöntemi çağrıldığında subscribe()
tarafından çağrılan kullanıcı tarafından EventHubConsumerClient
uygulanacak işlevleri açıklayan arabirim.
Özellikler
process |
Abonelik bir bölümden olayları okumayı her durdurduğunda tarafından
|
process |
Olayları alırken veya kullanıcı tarafından sağlanan işlevlerden herhangi biri yürütülürken oluşan hatalar için tarafından
İstemci bu işlevi |
process |
Bir olay kümesi alındığında tarafından
Not: Alınan olayların boş bir dizi olması mümkündür.
içinde varsayılan |
process |
Abonelik bir bölümden okumaya başlamak üzere olduğunda tarafından İstemci yalnızca bu işlevin yürütülmesini tamamladıktan sonra bölüm için olayları almaya başlar (sağlanmışsa). Bu nedenle, zaman uyumsuz görevler de dahil olmak üzere tüm kurulum çalışmalarını gerçekleştirmek için bu işlevi kullanın. |
Özellik Ayrıntıları
processClose
Abonelik bir bölümden olayları okumayı her durdurduğunda tarafından EventHubConsumerClient
çağrılan işlev. Bu bölümdeki bilgiler işlevine PartitionContext
processClose
geçirilen üzerinde kullanılabilir.
CloseReason
Bu işleve geçirilen iseOwnershipLost
, başka bir abonelik aynı tüketici grubunu kullanarak aynı bölümden okumayı devralmıştır. Uygulamanızın birden çok örneği çalışıyorsa ve yük dengelemesi için istemciye geçirdiyseniz CheckpointStore
bu beklenen bir durumdur.
CloseReason
iseShutdown
, bu, çağrıldığını subscription.close()
veya bir hata oluştuğunun göstergesidir. Abonelik üzerinden subscription.close()
açıkça kapatılmadığı sürece, abonelik bölümün son denetim noktasından okuma olaylarını sürdürmeye çalışır.
processClose?: ProcessCloseHandler
Özellik Değeri
processError
Olayları alırken veya kullanıcı tarafından sağlanan işlevlerden herhangi biri yürütülürken oluşan hatalar için tarafından EventHubConsumerClient
çağrılan işlev yöntemine subscribe()
geçirildi.
PartitionContext
Bu işleve geçirilen, hata oluştuğunda işlenen bölümü gösterir. Bir bölümden olayları işlemenin dışında bir hatanın oluştuğu durumlarda (örneğin yük dengelemenin başarısız olması), partitionId
bağlam üzerindeki boş bir dize olur.
İstemci bu işlevi partitionClose
yürütmeyi tamamladıktan sonra işlev çağrılır.
processError: ProcessErrorHandler
Özellik Değeri
processEvents
Bir olay kümesi alındığında tarafından EventHubConsumerClient
çağrılan işlev. PartitionContext
Bu işleve geçirilen, hangi bölümden okunmakta olduğunu belirlemek için kullanılabilir.
updateCheckpoint()
Bağlam üzerindeki yöntemi, içindeki denetim noktalarını CheckpointStore
güncelleştirmek için kullanılabilir (istemciye sağlanmışsa). Yeniden başlatma veya hata kurtarma durumunda istemcinin bu tür denetim noktalarından yeniden başlatabilmesi için işlenen olayları işaretlemek için bunu sık aralıklarla kullanın.
Not: Alınan olayların boş bir dizi olması mümkündür.
içinde varsayılan maxWaitTimeInSeconds
olarak 60 saniye olarak belirlenmiş yeni olay yoksa bu durum oluşabilir.
, maxWaitTimeInSeconds
içinde olarak subscribe()
ayarlanarak options
değiştirilebilir.
processEvents: ProcessEventsHandler
Özellik Değeri
processInitialize
Abonelik bir bölümden okumaya başlamak üzere olduğunda tarafından EventHubConsumerClient
çağrılan işlev. PartitionContext
Bu işleve geçirilen, hangi bölümün okunmak üzere olduğunu belirlemek için kullanılabilir.
İstemci yalnızca bu işlevin yürütülmesini tamamladıktan sonra bölüm için olayları almaya başlar (sağlanmışsa). Bu nedenle, zaman uyumsuz görevler de dahil olmak üzere tüm kurulum çalışmalarını gerçekleştirmek için bu işlevi kullanın.
processInitialize?: ProcessInitializeHandler