Dela via

ChangeFeedPullModelIterator interface

  • Referens
Paket:
@azure/cosmos

Använd Items.getChangeFeedIterator() för att returnera en iterator som kan iterera över alla ändringar för en partitionsnyckel, ett flödesintervall eller en hel container.

Egenskaper

hasMoreResults

Returnerar alltid sant, changefeed är en oändlig ström.

Metoder

getAsyncIterator()

Hämtar en asynkron iterator som ger resultat från ändringsflödet.

Exempel

Hämta ändringsfeed för en hel container från och med nu

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

Returnerar nästa resultatuppsättning för ändringsflödet.

Egenskapsinformation

hasMoreResults

Returnerar alltid sant, changefeed är en oändlig ström.

hasMoreResults: boolean

Egenskapsvärde

boolean

Metodinformation

getAsyncIterator()

Hämtar en asynkron iterator som ger resultat från ändringsflödet.

Exempel

Hämta ändringsfeed för en hel container från och med nu

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

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

Returer

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

readNext()

Returnerar nästa resultatuppsättning för ändringsflödet.

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

Returer

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