DocumentDB、SPでcontinuationTokenを使用する方法

Question

次のSPは、コレクションを実行し、次のバッチのドキュメント（バッチごとに10ドキュメント）のクエリを保持するとします。代わりに毎回同じ10の文書を返す。あなたが書いたスクリプトで

function sample(prefix) { 
var continuations = [], 
ids = [], 
context = getContext(), 
    collection = context.getCollection(), 
    response = context.getResponse(); 
var queryOptions = { pageSize: 10, continuation: null }; 

for (i = 0; i < 10; i++) { 
    // get all user wish list actions 
    var query = "select * from w", 
    accept = collection.queryDocuments(collection.getSelfLink(), query, queryOptions, processMultiUsers); 
    if (!accept) throw "Unable to read user's sessions"; 
} 
getContext().getResponse().setBody(ids); 


function processMultiUsers(err, docs, options) { 
    if (err) throw new Error("Error: " + err.message); 
    if (docs == undefined || docs.length == 0) throw new Error("Warning: Users not exists"); 

    for (j = 0; j < docs.length; j++) { 
     ids.push(docs[j].UserId); 
    } 
    queryOptions.continuation = options.continuation; 
    continuations.push(options.continuation); 
}} 

Answer 1

、クエリの実行は同期的に行われており、それらがnullである同じ初期継続トークン、でキューに入れられています。代わりに、最初のクエリからトークンを取得し、次のクエリをキューに入れて続行する必要があります。

以下のサンプルでは、​​私はちょうどあなたのカウントの質問に書いた答えでかいま見を取り、それがあなたの質問に答えるかどうかを確認あなたは

function sample(continuationToken) { 
    var collection = getContext().getCollection(); 
    var maxResult = 10; 
    var documentsProcessed = 0; 
    var ids = []; 
    var filterQuery = "select * from w"; 

    tryQuery(continuationToken); 

    function tryQuery(nextContinuationToken) { 
     var responseOptions = { continuation: nextContinuationToken, pageSize: maxResult }; 
     if (documentsProcessed >= maxResult || !query(responseOptions)) { 
      setBody(nextContinuationToken); 
     } 
    } 

    function query(responseOptions) { 
     return (filterQuery && filterQuery.length) ? 
      collection.queryDocuments(collection.getSelfLink(), filterQuery, responseOptions, onReadDocuments) : 
      collection.readDocuments(collection.getSelfLink(), responseOptions, onReadDocuments); 
    } 

    function onReadDocuments(err, docFeed, responseOptions) { 
     if (err) { 
      throw 'Error while reading document: ' + err; 
     } 

     documentsProcessed += docFeed.length; 

     for (var i = 0; i < documentsProcessed; i++) { 
      ids.push(docFeed[i].UserId); 
     } 

     if (responseOptions.continuation) { 
      tryQuery(responseOptions.continuation); 
     } else { 
      setBody(null); 
     } 
    } 

    function setBody(continuationToken) { 
     var body = { continuationToken: continuationToken, documentsProcessed: documentsProcessed, ids: ids }; 
     getContext().getResponse().setBody(body); 
    } 
}