你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

Container.ChangeFeedHandlerWithManualCheckpoint<T> 委托

定义

命名空间:

Microsoft.Azure.Cosmos

程序集:

Microsoft.Azure.Cosmos.Client.dll

包:

Microsoft.Azure.Cosmos v3.39.0

Source:

Container.cs

委托以使用手动检查点接收执行中的 ChangeFeedProcessor 更改。

public delegate System.Threading.Tasks.Task Container.ChangeFeedHandlerWithManualCheckpoint<T>(ChangeFeedProcessorContext context, IReadOnlyCollection<T> changes, Func<Task> checkpointAsync, CancellationToken cancellationToken);

type Container.ChangeFeedHandlerWithManualCheckpoint<'T> = delegate of ChangeFeedProcessorContext * IReadOnlyCollection<'T> * Func<Task> * CancellationToken -> Task

Public Delegate Function Container.ChangeFeedHandlerWithManualCheckpoint(Of T)(context As ChangeFeedProcessorContext, changes As IReadOnlyCollection(Of T), checkpointAsync As Func(Of Task), cancellationToken As CancellationToken) As Task 

类型参数

T

参数

context

ChangeFeedProcessorContext

与更改相关的上下文。

changes

IReadOnlyCollection<T>

发生的更改。

checkpointAsync

Func<Task>

表示租约进度的异步检查点的任务。

cancellationToken

CancellationToken

表示实例的当前取消状态的 ChangeFeedProcessor 取消标记。

返回值

Task

一个 Task ，表示将完成更改的异步操作。

示例

(ChangeFeedProcessorContext context, IReadOnlyCollection<T> changes, Func<Task> checkpointAsync, CancellationToken cancellationToken) =>
{
    // consume changes

    // On certain condition, we can checkpoint
    await checkpointAsync();
}