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 PartitionContextprocessClosegeç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 maxWaitTimeInSecondsolarak 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