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

IDocumentClient.CreateDocumentChangeFeedQuery 方法

参考

定义

命名空间:: Microsoft.Azure.Documents

程序集:: Microsoft.Azure.DocumentDB.Core.dll, Microsoft.Azure.Documents.Client.dll

包:: Microsoft.Azure.DocumentDB v2.18.0, Microsoft.Azure.DocumentDB.Core v2.18.0

重要

一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。

重载

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)	已重载。此方法为 Azure Cosmos DB 服务中的集合下的文档创建更改源查询。
CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)	用于为 Azure Cosmos DB 服务中的文档创建更改源查询的扩展方法。

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)

已重载。此方法为 Azure Cosmos DB 服务中的集合下的文档创建更改源查询。

public Microsoft.Azure.Documents.Linq.IDocumentQuery<Microsoft.Azure.Documents.Document> CreateDocumentChangeFeedQuery (string collectionLink, Microsoft.Azure.Documents.Client.ChangeFeedOptions feedOptions);

abstract member CreateDocumentChangeFeedQuery : string * Microsoft.Azure.Documents.Client.ChangeFeedOptions -> Microsoft.Azure.Documents.Linq.IDocumentQuery<Microsoft.Azure.Documents.Document>

Public Function CreateDocumentChangeFeedQuery (collectionLink As String, feedOptions As ChangeFeedOptions) As IDocumentQuery(Of Document)

参数

collectionLink: String

指定要从中读取文档的集合。

feedOptions: ChangeFeedOptions

用于处理查询结果源的选项。

IDocumentQuery<Document>

查询结果集。

示例

string partitionKeyRangeId = "0";   // Use client.ReadPartitionKeyRangeFeedAsync() to obtain the ranges.
string checkpointContinuation = null;
ChangeFeedOptions options = new ChangeFeedOptions
{
    PartitionKeyRangeId = partitionKeyRangeId,
    RequestContinuation = checkpointContinuation,
    StartFromBeginning = true,
};
using(var query = client.CreateDocumentChangeFeedQuery(collection.SelfLink, options))
{
    while (true)
    {
        do
        {
            var response = await query.ExecuteNextAsync<Document>();
            if (response.Count > 0)
            {
                var docs = new List<Document>();
                docs.AddRange(response);
                // Process the documents.
                // Checkpoint response.ResponseContinuation.
            }
        }
        while (query.HasMoreResults);
        Task.Delay(TimeSpan.FromMilliseconds(500)); // Or break here and use checkpointed continuation token later.
    }       
}

注解

必须提供 ChangeFeedOptions.PartitionKeyRangeId。

另请参阅

适用于

CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)

用于为 Azure Cosmos DB 服务中的文档创建更改源查询的扩展方法。

public Microsoft.Azure.Documents.Linq.IDocumentQuery<Microsoft.Azure.Documents.Document> CreateDocumentChangeFeedQuery (Uri collectionLink, Microsoft.Azure.Documents.Client.ChangeFeedOptions feedOptions);

abstract member CreateDocumentChangeFeedQuery : Uri * Microsoft.Azure.Documents.Client.ChangeFeedOptions -> Microsoft.Azure.Documents.Linq.IDocumentQuery<Microsoft.Azure.Documents.Document>

Public Function CreateDocumentChangeFeedQuery (collectionLink As Uri, feedOptions As ChangeFeedOptions) As IDocumentQuery(Of Document)

参数

collectionLink: Uri