共用方式為

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)

參數

名稱 Description
fully_qualified_namespace
必要
eventhub_name
必要
consumer_group
必要
partition_id
必要
checkpoint_store
預設值: None

方法

update_checkpoint

更新接收檢查點到指定的事件位移。

update_checkpoint

更新接收檢查點到指定的事件位移。

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

參數

名稱 Description
event
EventData

EventData 實例，其中包含用於檢查點的位移和序號資訊。

預設值: None

傳回

類型 Description
None

屬性

last_enqueued_event_properties

最新的排入佇列事件資訊。

如果接收者建立 track_last_enqueued_event_properties設定為True，則每次收到事件時，都會更新此屬性。 屬性聽寫包含最後一個排入佇列事件的下列資訊：

  • sequence_number int ( int)

  • offset (str)

  • enqueued_time (UTC datetime.datetime)

  • retrieval_time UTC datetime.datetime) (

傳回

類型 Description
Dict[str, Any],
None