ChangeFeedPullModelIterator interface
Olyan iterátor visszaadására használható Items.getChangeFeedIterator()
, amely egy partíciókulcs, adatcsatornatartomány vagy egy teljes tároló összes változását át tudja iterálni.
Tulajdonságok
has |
Mindig igaz értéket ad vissza, a changefeed egy végtelen stream. |
Metódusok
get |
Lekér egy aszinkron iterátort, amely változáscsatorna-eredményeket ad. Példa Változáscsatorna lekérése egy teljes tárolóhoz mostantól
|
read |
A változáscsatorna következő eredményhalmazát adja vissza. |
Tulajdonság adatai
hasMoreResults
Mindig igaz értéket ad vissza, a changefeed egy végtelen stream.
hasMoreResults: boolean
Tulajdonság értéke
boolean
Metódus adatai
getAsyncIterator()
Lekér egy aszinkron iterátort, amely változáscsatorna-eredményeket ad.
Példa
Változáscsatorna lekérése egy teljes tárolóhoz mostantól
const options = { changeFeedStartFrom: ChangeFeedStartFrom.Now() };
for await(const res of container.items.getChangeFeedIterator(options).getAsyncIterator()) {
//process res
}
function getAsyncIterator(): AsyncIterable<ChangeFeedIteratorResponse<(T & Resource)[]>>
Válaszok
AsyncIterable<ChangeFeedIteratorResponse<(T & Resource)[]>>
readNext()
A változáscsatorna következő eredményhalmazát adja vissza.
function readNext(): Promise<ChangeFeedIteratorResponse<(T & Resource)[]>>
Válaszok
Promise<ChangeFeedIteratorResponse<(T & Resource)[]>>