Sdílet prostřednictvím

ChangeFeedPullModelIterator interface

  • Reference
Balíček:
@azure/cosmos

Pomocí Items.getChangeFeedIterator() můžete vrátit iterátor, který může iterovat všechny změny klíče oddílu, rozsahu informačních kanálů 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ý získá výsledky kanálu změn.

příklad

Get changefeed for an entire container from now

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

Vrátí další sadu výsledků kanálu 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ý získá výsledky kanálu změn.

příklad

Get changefeed for an entire container from now

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ů kanálu změn.

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

Návraty

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