DocumentClient.CreateDocumentChangeFeedQuery Methode
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Ü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
das Abfrageergebnisset.
Implementiert
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
das Abfrageergebnisset.
Implementiert
Gilt für:
Azure SDK for .NET