Freigeben über

ChangeFeedPullModelIterator interface

  • Referenz
Paket:
@azure/cosmos

Verwenden Sie Items.getChangeFeedIterator(), um einen Iterator zurückzugeben, der alle Änderungen für einen Partitionsschlüssel, einen Feedbereich oder einen gesamten Container durchlaufen kann.

Eigenschaften

hasMoreResults

Gibt immer "true" zurück, "Changefeed" ist ein unendlicher Datenstrom.

Methoden

getAsyncIterator()

Ruft einen asynchronen Iterator ab, der Änderungsfeedergebnisse liefert.

Beispiel

Abrufen des Änderungsfeeds für einen gesamten Container ab sofort

const options = { changeFeedStartFrom: ChangeFeedStartFrom.Now() };
for await(const res of container.items.getChangeFeedIterator(options).getAsyncIterator()) {
  //process res
}
readNext()

Gibt den nächsten Ergebnissatz für den Änderungsfeed zurück.

Details zur Eigenschaft

hasMoreResults

Gibt immer "true" zurück, "Changefeed" ist ein unendlicher Datenstrom.

hasMoreResults: boolean

Eigenschaftswert

boolean

Details zur Methode

getAsyncIterator()

Ruft einen asynchronen Iterator ab, der Änderungsfeedergebnisse liefert.

Beispiel

Abrufen des Änderungsfeeds für einen gesamten Container ab sofort

const options = { changeFeedStartFrom: ChangeFeedStartFrom.Now() };
for await(const res of container.items.getChangeFeedIterator(options).getAsyncIterator()) {
  //process res
}

function getAsyncIterator(): AsyncIterable<ChangeFeedIteratorResponse<(T & Resource)[]>>

Gibt zurück

AsyncIterable<ChangeFeedIteratorResponse<(T & Resource)[]>>

readNext()

Gibt den nächsten Ergebnissatz für den Änderungsfeed zurück.

function readNext(): Promise<ChangeFeedIteratorResponse<(T & Resource)[]>>

Gibt zurück

Promise<ChangeFeedIteratorResponse<(T & Resource)[]>>