Поделиться через

ChangeFeedPullModelIterator interface

  • Ссылка
Пакет:
@azure/cosmos

Используйте для Items.getChangeFeedIterator() возврата итератора, который может выполнять итерацию по всем изменениям для ключа секции, диапазона канала или всего контейнера.

Свойства

hasMoreResults

Всегда возвращает значение true, changefeed является бесконечным потоком.

Методы

getAsyncIterator()

Возвращает асинхронный итератор, который возвращает результаты канала изменений.

Пример

Получение канала изменений для всего контейнера с этого момента

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

Возвращает следующий набор результатов для канала изменений.

Сведения о свойстве

hasMoreResults

Всегда возвращает значение true, changefeed является бесконечным потоком.

hasMoreResults: boolean

Значение свойства

boolean

Сведения о методе

getAsyncIterator()

Возвращает асинхронный итератор, который возвращает результаты канала изменений.

Пример

Получение канала изменений для всего контейнера с этого момента

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

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

Возвращаемое значение

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

readNext()

Возвращает следующий набор результатов для канала изменений.

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

Возвращаемое значение

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