Delen via

ChangeFeedPullModelIterator interface

  • Referentie
Pakket:
@azure/cosmos

Gebruik Items.getChangeFeedIterator() om een iterator te retourneren die alle wijzigingen voor een partitiesleutel, feedbereik of een hele container kan herhalen.

Eigenschappen

hasMoreResults

Retourneert altijd waar, changefeed is een oneindige stroom.

Methoden

getAsyncIterator()

Hiermee haalt u een asynchrone iterator op die resultaten van de wijzigingenfeed oplevert.

Voorbeeld

Vanaf nu wijzigingsfeed voor een hele container ophalen

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

Retourneert de volgende set resultaten voor de wijzigingenfeed.

Eigenschapdetails

hasMoreResults

Retourneert altijd waar, changefeed is een oneindige stroom.

hasMoreResults: boolean

Waarde van eigenschap

boolean

Methodedetails

getAsyncIterator()

Hiermee haalt u een asynchrone iterator op die resultaten van de wijzigingenfeed oplevert.

Voorbeeld

Vanaf nu wijzigingsfeed voor een hele container ophalen

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

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

Retouren

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

readNext()

Retourneert de volgende set resultaten voor de wijzigingenfeed.

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

Retouren

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