Freigeben über

DocumentClient.CreateDocumentChangeFeedQuery Methode

  • Referenz

Definition

Namespace:
Microsoft.Azure.Documents.Client
Assemblys:
Microsoft.Azure.DocumentDB.Core.dll, Microsoft.Azure.Documents.Client.dll
Pakete:
Microsoft.Azure.DocumentDB v2.18.0, Microsoft.Azure.DocumentDB.Core v2.18.0

Überlädt

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)

Überladen. Diese Methode erstellt eine Änderungsfeedabfrage für Dokumente unter einer Sammlung in einem Azure Cosmos DB-Dienst.
CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)

Erweiterungsmethode zum Erstellen einer Änderungsfeedabfrage für Dokumente im Azure Cosmos DB-Dienst.

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)

Überladen. Diese Methode erstellt eine Änderungsfeedabfrage für Dokumente unter einer Sammlung in einem Azure Cosmos DB-Dienst.

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>
override this.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)

Parameter

collectionLink
String

Gibt die Auflistung an, aus der Dokumente gelesen werden sollen.

feedOptions
ChangeFeedOptions

Die Optionen für die Verarbeitung des Abfrageergebnisfeeds.

Gibt zurück

IDocumentQuery<Document>

das Abfrageergebnisset.

Implementiert

CreateDocumentChangeFeedQuery(String, ChangeFeedOptions)

Beispiele

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

Hinweise

ChangeFeedOptions.PartitionKeyRangeId muss bereitgestellt werden.

Weitere Informationen

Gilt für:

CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)

Erweiterungsmethode zum Erstellen einer Änderungsfeedabfrage für Dokumente im Azure Cosmos DB-Dienst.

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>
override this.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)

Parameter

collectionLink
Uri

Gibt die Auflistung an, aus der Dokumente gelesen werden sollen.

feedOptions
ChangeFeedOptions

Die Optionen für die Verarbeitung des Abfrageergebnisfeeds.

Gibt zurück

IDocumentQuery<Document>

das Abfrageergebnisset.

Implementiert

CreateDocumentChangeFeedQuery(Uri, ChangeFeedOptions)

Gilt für: