Aracılığıyla paylaş

ChangeFeedPullModelIterator interface

  • Başvuru
Paket:
@azure/cosmos

Bölüm anahtarı, akış aralığı veya kapsayıcının tamamı için tüm değişiklikleri yineleyebilecek bir yineleyici döndürmek için kullanın Items.getChangeFeedIterator() .

Özellikler

hasMoreResults

Her zaman true döndürür, değişiklik akışı sonsuz bir akıştır.

Yöntemler

getAsyncIterator()

Değişiklik akışı sonuçlarını verecek zaman uyumsuz bir yineleyici alır.

Örnek

Şu andan itibaren kapsayıcının tamamı için değişiklik akışı alma

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

Değişiklik akışı için sonraki sonuç kümesini döndürür.

Özellik Ayrıntıları

hasMoreResults

Her zaman true döndürür, değişiklik akışı sonsuz bir akıştır.

hasMoreResults: boolean

Özellik Değeri

boolean

Yöntem Ayrıntıları

getAsyncIterator()

Değişiklik akışı sonuçlarını verecek zaman uyumsuz bir yineleyici alır.

Örnek

Şu andan itibaren kapsayıcının tamamı için değişiklik akışı alma

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

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

Döndürülenler

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

readNext()

Değişiklik akışı için sonraki sonuç kümesini döndürür.

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

Döndürülenler

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