PartitionContext interface

SubscriptionEventHandlersparçası olan işlevlerin her birine geçirilen bağlamı açıklayan arabirim. Bu işlevlerden herhangi birini uygularken, bölüm ve denetim noktası özelliği hakkında bilgi almak için bağlam nesnesini kullanın.

Özellikler

consumerGroup

Tüketici grubu adı.

eventHubName

Olay hub'ı adı.

fullyQualifiedNamespace

Tam Event Hubs ad alanı. Bu büyük olasılıkla <yournamespace.servicebus.windows.net>

lastEnqueuedEventProperties

İşlenmekte olan bölümdeki en son sıraya alınan olayla ilgili bilgiler. Bu özellik yalnızca EventProcessor örneği oluşturulurken trackLastEnqueuedEventProperties seçeneği true olarak ayarlandığında güncelleştirilir.

partitionId

Olay Hub'ı bölümünün tanımlayıcısı.

Yöntemler

updateCheckpoint(ReceivedEventData)

Olay verilerini kullanarak denetim noktasını güncelleştirir.

Denetim noktası, kullanıcı tarafından olay hub'ı örneğindeki bir tüketici grubunun belirli bir bölümünden başarıyla işlenen son olayı temsil etmek için kullanılır.

Özellik Ayrıntıları

consumerGroup

Tüketici grubu adı.

consumerGroup: string

Özellik Değeri

string

eventHubName

Olay hub'ı adı.

eventHubName: string

Özellik Değeri

string

fullyQualifiedNamespace

Tam Event Hubs ad alanı. Bu büyük olasılıkla <yournamespace.servicebus.windows.net>

fullyQualifiedNamespace: string

Özellik Değeri

string

lastEnqueuedEventProperties

İşlenmekte olan bölümdeki en son sıraya alınan olayla ilgili bilgiler. Bu özellik yalnızca EventProcessor örneği oluşturulurken trackLastEnqueuedEventProperties seçeneği true olarak ayarlandığında güncelleştirilir.

lastEnqueuedEventProperties?: LastEnqueuedEventProperties

Özellik Değeri

partitionId

Olay Hub'ı bölümünün tanımlayıcısı.

partitionId: string

Özellik Değeri

string

Yöntem Ayrıntıları

updateCheckpoint(ReceivedEventData)

Olay verilerini kullanarak denetim noktasını güncelleştirir.

Denetim noktası, kullanıcı tarafından olay hub'ı örneğindeki bir tüketici grubunun belirli bir bölümünden başarıyla işlenen son olayı temsil etmek için kullanılır.

function updateCheckpoint(eventData: ReceivedEventData): Promise<void>

Parametreler

eventData
ReceivedEventData

Denetim noktasını güncelleştirmek istediğiniz olay.

Döndürülenler

Promise<void>