Compartilhar via

ChangeFeedPullModelIterator interface

  • Referência
Pacote:
@azure/cosmos

Use Items.getChangeFeedIterator() para retornar um iterador que pode iterar todas as alterações de uma chave de partição, um intervalo de feed ou um contêiner inteiro.

Propriedades

hasMoreResults

Sempre retorna true, changefeed é um fluxo infinito.

Métodos

getAsyncIterator()

Obtém um iterador assíncrono que produzirá resultados do feed de alterações.

Exemplo

Obter o changefeed de um contêiner inteiro a partir de agora

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

Retorna o próximo conjunto de resultados para o feed de alterações.

Detalhes da propriedade

hasMoreResults

Sempre retorna true, changefeed é um fluxo infinito.

hasMoreResults: boolean

Valor da propriedade

boolean

Detalhes do método

getAsyncIterator()

Obtém um iterador assíncrono que produzirá resultados do feed de alterações.

Exemplo

Obter o changefeed de um contêiner inteiro a partir de agora

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

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

Retornos

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

readNext()

Retorna o próximo conjunto de resultados para o feed de alterações.

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

Retornos

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