Condividi tramite

ChangeFeedPullModelIterator interface

  • Riferimento
Pacchetto:
@azure/cosmos

Usare Items.getChangeFeedIterator() per restituire un iteratore che può scorrere tutte le modifiche per una chiave di partizione, un intervallo di feed o un intero contenitore.

Proprietà

hasMoreResults

Restituisce sempre true, changefeed è un flusso infinito.

Metodi

getAsyncIterator()

Ottiene un iteratore asincrono che restituirà i risultati del feed di modifiche.

Esempio

Ottenere il changefeed per un intero contenitore da ora

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

Restituisce il set successivo di risultati per il feed di modifiche.

Dettagli proprietà

hasMoreResults

Restituisce sempre true, changefeed è un flusso infinito.

hasMoreResults: boolean

Valore della proprietà

boolean

Dettagli metodo

getAsyncIterator()

Ottiene un iteratore asincrono che restituirà i risultati del feed di modifiche.

Esempio

Ottenere il changefeed per un intero contenitore da ora

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

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

Restituisce

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

readNext()

Restituisce il set successivo di risultati per il feed di modifiche.

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

Restituisce

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