PartitionContext クラス

パーティション関連のコンテキスト情報が含まれます。

PartitionContext インスタンスは、EventHubConsumerClient.receive() を呼び出すときに定義されたイベント、エラー、および初期化コールバックに渡されます。 ユーザーは、このクラス の update_checkpoint() を呼び出してチェックポイント データを保持できます。

継承

builtins.object

PartitionContext

コンストラクター

PartitionContext(fully_qualified_namespace: str, eventhub_name: str, consumer_group: str, partition_id: str, checkpoint_store: CheckpointStore | None = None)

パラメーター

名前	説明
fully_qualified_namespace 必須
eventhub_name 必須
consumer_group 必須
partition_id 必須
checkpoint_store	既定値: None

メソッド

update_checkpoint

受信チェックポイントを指定されたイベント オフセットに更新します。

update_checkpoint

受信チェックポイントを指定されたイベント オフセットに更新します。

async update_checkpoint(event: EventData | None = None, **kwargs: Any) -> None

パラメーター

名前	説明
event	EventData チェックポイントに使用されるオフセットとシーケンス番号の情報を含む EventData インスタンス。 既定値: None

戻り値

型	説明
None

属性

last_enqueued_event_properties

エンキューされた最新のイベント情報。

このプロパティは、レシーバーが作成され、 track_last_enqueued_event_propertiesTrue に設定されている場合、イベントが受信されるたびに更新されます。 プロパティ dict には、最後にエンキューされたイベントの次の情報が含まれます。

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

戻り値

型	説明
dict, None