Compartilhar via

IDocumentClient.CreateDocumentChangeFeedQuery Método

  • Referência

Definição

Namespace:
Microsoft.Azure.Documents
Assemblies:
Microsoft.Azure.DocumentDB.Core.dll, Microsoft.Azure.Documents.Client.dll
Pacotes:
Microsoft.Azure.DocumentDB v2.18.0, Microsoft.Azure.DocumentDB.Core v2.18.0

Sobrecargas

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)

Sobrecarregado. Esse método cria uma consulta de feed de alterações para documentos em uma coleção em um serviço do Azure Cosmos DB.
CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)

Método de extensão para criar uma consulta de feed de alterações para documentos no serviço do Azure Cosmos DB.

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)

Sobrecarregado. Esse método cria uma consulta de feed de alterações para documentos em uma coleção em um serviço do 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)

Parâmetros

collectionLink
String

Especifica a coleção da qual ler documentos.

feedOptions
ChangeFeedOptions

As opções para processar o feed de resultados da consulta.

Retornos

IDocumentQuery<Document>

o conjunto de resultados da consulta.

Exemplos

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.
    }       
}

Comentários

ChangeFeedOptions.PartitionKeyRangeId deve ser fornecido.

Confira também

Aplica-se a

CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)

Método de extensão para criar uma consulta de feed de alterações para documentos no serviço do 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)

Parâmetros

collectionLink
Uri

Especifica a coleção da qual ler documentos.

feedOptions
ChangeFeedOptions

As opções para processar o feed de resultados da consulta.

Retornos

IDocumentQuery<Document>

o conjunto de resultados da consulta.

Aplica-se a