问Cosmosdb存储过程得到的文档比实际的少

EN

var query = 'SELECT COUNT(1) AS Num FROM AISData a WHERE a.TransmitterMMSI="' + transmitterMMSI + '"';

var query = 'SELECT * FROM AISData a WHERE a.TransmitterMMSI="' + transmitterMMSI + '"';

function DownSampling(transmitterMMSI, interval) {
var context = getContext();
var collection = context.getCollection();
var response = context.getResponse();
var receiverTime;
var tempTime;
var groupKey;
var aggGroup = new Object();

var query = 'SELECT * FROM AISData a WHERE a.TransmitterMMSI="' + transmitterMMSI + '"';
var accept = collection.queryDocuments(collection.getSelfLink(), query, { pageSize: -1},
    function (err, documents, responseOptions) {
        if (err) throw new Error("Error" + err.message);

        // Find the smallest deviation comparting to IntervalTime in each group
        for (i = 0; i < documents.length; i++) {
            receiverTime = Date.parse(documents[i].ReceiverTime);
            tempTime = receiverTime / 1000 + interval / 2;
            documents[i].IntervalTime = (tempTime - tempTime % interval) * 1000;
            documents[i].Deviation = Math.abs(receiverTime - documents[i].IntervalTime);

            // Generate a group key for each group, combinated of TransmitterMMSI and IntervalTime
            groupKey = documents[i].IntervalTime.toString();
            if (typeof aggGroup[groupKey] === 'undefined' || aggGroup[groupKey] > documents[i].Deviation) {
                aggGroup[groupKey] = documents[i].Deviation;
            }
        }

        // Tag the downsampling
        for (i = 0; i < documents.length; i++) {
            groupKey = documents[i].IntervalTime;
            if (aggGroup[groupKey] == documents[i].Deviation) {
                documents[i].DownSamplingTag = 1;
            } else {
                documents[i].DownSamplingTag = 0;
            }

            // Remove the items that are not used
            delete documents[i].IntervalTime;
            delete documents[i].Deviation;

            // Replace the document
            var acceptDoc = collection.replaceDocument(documents[i]._self, documents[i], {},
                function (errDoc, docReplaced) {
                    if (errDoc) {
                        throw new Error("Update documents error:" + errDoc.message);
                    }
                });
            if (!acceptDoc) {
                throw "Update documents not accepted, abort ";
            } 
        } 
        response.setBody(documents.length);
    });
if (!accept) {
    throw new Error("The stored procedure timed out.");
}
} 

    private async Task DownSampling()
    {
        Database database = this.client.CreateDatabaseQuery().Where(db => db.Id == DatabaseId).ToArray().FirstOrDefault();
        DocumentCollection collection = this.client.CreateDocumentCollectionQuery(database.SelfLink).Where(c => c.Id == AISTestCollectionId).ToArray().FirstOrDefault();

        string scriptFileName = @"..\..\StoredProcedures\DownSampling.js";
        string scriptId = Path.GetFileNameWithoutExtension(scriptFileName);

        var sproc = new StoredProcedure
        {
            Id = scriptId,
            Body = File.ReadAllText(scriptFileName)
        };

        await TryDeleteStoredProcedure(collection.SelfLink, sproc.Id);
        sproc = await this.client.CreateStoredProcedureAsync(collection.SelfLink, sproc);

        IQueryable<dynamic> query = this.client.CreateDocumentQuery(
            UriFactory.CreateDocumentCollectionUri(DatabaseId, AISTestCollectionId),
            new SqlQuerySpec()
            {
                //QueryText = "SELECT a.TransmitterMMSI FROM " + AISTestCollectionId + " a",
                QueryText = "SELECT a.TransmitterMMSI FROM " + AISTestCollectionId + " a WHERE a.TransmitterMMSI=\"219633000\"",
            }, new FeedOptions { MaxItemCount = -1, EnableCrossPartitionQuery = true, MaxDegreeOfParallelism = -1, MaxBufferedItemCount = -1 });

        List<dynamic> transmitterMMSIList = query.ToList(); //TODO: Remove duplicates
        Console.WriteLine("TransmitterMMSI count: {0}", transmitterMMSIList.Count());
        HashSet<string> exist = new HashSet<string>();

        foreach (var item in transmitterMMSIList)
        {
            //int transmitterMMSI = Int32.Parse(item.TransmitterMMSI.ToString());
            string transmitterMMSI = item.TransmitterMMSI.ToString();

            if (exist.Contains(transmitterMMSI))
            {
                continue;
            }
            exist.Add(transmitterMMSI);
            Console.WriteLine("TransmitterMMSI: {0} is being processed.", transmitterMMSI);
            var response = await this.client.ExecuteStoredProcedureAsync<string>(sproc.SelfLink,
                new RequestOptions { PartitionKey = new PartitionKey(transmitterMMSI) }, transmitterMMSI, 30);
            string s = response.Response;
            Console.WriteLine("TransmitterMMSI: {0} is processed completely.", transmitterMMSI);
        }
    }

    private async Task TryDeleteStoredProcedure(string collectionSelfLink, string sprocId)
    {
        StoredProcedure sproc = this.client.CreateStoredProcedureQuery(collectionSelfLink).Where(s => s.Id == sprocId).AsEnumerable().FirstOrDefault();
        if (sproc != null)
        {
            await client.DeleteStoredProcedureAsync(sproc.SelfLink);
        }
    }