Share via


ChangeFeedPullModelIterator interface

Utilize Items.getChangeFeedIterator() para devolver um iterador que pode iterar todas as alterações de uma chave de partição, intervalo de feed ou um contentor inteiro.

Propriedades

hasMoreResults

Devolve sempre verdadeiro, o 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 para um contentor inteiro a partir de agora

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

Devolve o próximo conjunto de resultados do feed de alterações.

Detalhes de Propriedade

hasMoreResults

Devolve sempre verdadeiro, o changefeed é um fluxo infinito.

hasMoreResults: boolean

Valor de Propriedade

boolean

Detalhes de Método

getAsyncIterator()

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

Exemplo

Obter o changefeed para um contentor 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)[]>>

Devoluções

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

readNext()

Devolve o próximo conjunto de resultados do feed de alterações.

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

Devoluções