Udostępnij za pośrednictwem

ChangeFeedPullModelIterator interface

  • Odwołanie
Pakiet:
@azure/cosmos

Służy Items.getChangeFeedIterator() do zwracania iteratora, który może iterować wszystkie zmiany klucza partycji, zakresu kanału informacyjnego lub całego kontenera.

Właściwości

hasMoreResults

Zawsze zwraca wartość true, wartość changefeed jest nieskończonym strumieniem.

Metody

getAsyncIterator()

Pobiera iterator asynchroniczny, który przyniesie wyniki zestawienia zmian.

Przykład

Pobieranie kanału zmian dla całego kontenera od teraz

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

Zwraca następny zestaw wyników zestawienia zmian.

Szczegóły właściwości

hasMoreResults

Zawsze zwraca wartość true, wartość changefeed jest nieskończonym strumieniem.

hasMoreResults: boolean

Wartość właściwości

boolean

Szczegóły metody

getAsyncIterator()

Pobiera iterator asynchroniczny, który przyniesie wyniki zestawienia zmian.

Przykład

Pobieranie kanału zmian dla całego kontenera od teraz

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

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

Zwraca

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

readNext()

Zwraca następny zestaw wyników zestawienia zmian.

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

Zwraca

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