Sdílet prostřednictvím

ChangeFeedPullModelIterator interface

  • Reference
Balíček:
@azure/cosmos

Slouží Items.getChangeFeedIterator() k vrácení iterátoru, který může iterovat všechny změny klíče oddílu, rozsahu informačního kanálu nebo celého kontejneru.

Vlastnosti

hasMoreResults

Vždy vrátí hodnotu true, changefeed je nekonečný datový proud.

Metody

getAsyncIterator()

Získá asynchronní iterátor, který bude poskytovat výsledky kanálu změn.

Příklad

Získání kanálu změn pro celý kontejner od této chvíle

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

Vrátí další sadu výsledků pro kanál změn.

Podrobnosti vlastnosti

hasMoreResults

Vždy vrátí hodnotu true, changefeed je nekonečný datový proud.

hasMoreResults: boolean

Hodnota vlastnosti

boolean

Podrobnosti metody

getAsyncIterator()

Získá asynchronní iterátor, který bude poskytovat výsledky kanálu změn.

Příklad

Získání kanálu změn pro celý kontejner od této chvíle

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

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

Návraty

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

readNext()

Vrátí další sadu výsledků pro kanál změn.

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

Návraty

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