Aracılığıyla paylaş

PartitionContext interface

  • Başvuru
Paket:
@azure/event-hubs

bir parçası SubscriptionEventHandlersolan 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 .servicebus.windows.net
lastEnqueuedEventProperties

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

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

Yöntemler

updateCheckpoint(ReceivedEventData)

Olay verilerini kullanarak denetim noktasını Güncelleştirmeler.

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

Ö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 .servicebus.windows.net

fullyQualifiedNamespace: string

Özellik Değeri

string

lastEnqueuedEventProperties

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

lastEnqueuedEventProperties?: LastEnqueuedEventProperties

Özellik Değeri

LastEnqueuedEventProperties

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ştirmeler.

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

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

Parametreler

eventData
ReceivedEventData

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

Döndürülenler

Promise<void>