ChangeFeedPullModelIterator interface

  • Referencia
Csomag:
@azure/cosmos

Olyan iterátor visszaadására használható Items.getChangeFeedIterator() , amely egy partíciókulcs, adatcsatornatartomány vagy egy teljes tároló összes változását át tudja iterálni.

Tulajdonságok

hasMoreResults

Mindig igaz értéket ad vissza, a changefeed egy végtelen stream.

Metódusok

getAsyncIterator()

Lekér egy aszinkron iterátort, amely változáscsatorna-eredményeket ad.

Példa

Változáscsatorna lekérése egy teljes tárolóhoz mostantól

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

A változáscsatorna következő eredményhalmazát adja vissza.

Tulajdonság adatai

hasMoreResults

Mindig igaz értéket ad vissza, a changefeed egy végtelen stream.

hasMoreResults: boolean

Tulajdonság értéke

boolean

Metódus adatai

getAsyncIterator()

Lekér egy aszinkron iterátort, amely változáscsatorna-eredményeket ad.

Példa

Változáscsatorna lekérése egy teljes tárolóhoz mostantól

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

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

Válaszok

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

readNext()

A változáscsatorna következő eredményhalmazát adja vissza.

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

Válaszok

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