PartitionContext 類別
包含資料分割相關內容資訊。
PartitionCoNtext實例會傳遞至呼叫EventHubConsumerClient.receive () 時所定義的事件、錯誤和初始化回呼。 使用者可以呼叫此類別的 update_checkpoint () 來保存檢查點資料。
- 繼承
-
builtins.objectPartitionContext
建構函式
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
更新指定事件位移的接收檢查點。
async update_checkpoint(event: EventData | None = None, **kwargs: Any) -> None
參數
名稱 | Description |
---|---|
event
|
EventData 實例,其中包含用於檢查點的位移和序號資訊。 預設值: None
|
傳回
類型 | Description |
---|---|