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

Methoden

getAsyncIterator()

Ruft einen asynchronen Iterator ab, der Änderungsfeedergebnisse liefert.

Beispiel

Abrufen des Changefeeds 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 Satz von Ergebnissen für den Änderungsfeed zurück.

Details zur Eigenschaft

hasMoreResults

Gibt immer true zurück, changefeed ist ein unendlicher Stream.

hasMoreResults: boolean

Eigenschaftswert

boolean

Details zur Methode

getAsyncIterator()

Ruft einen asynchronen Iterator ab, der Änderungsfeedergebnisse liefert.

Beispiel

Abrufen des Changefeeds 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 Satz von Ergebnissen für den Änderungsfeed zurück.

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

Gibt zurück

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