使用 IAsyncCursor 查询保证排序顺序？

Question

我正在使用一个异步填充数百万条记录的集合，因此无法保证顺序。

查询 MongoDB FindAsync 方法时将允许添加过滤器，但不允许添加排序。

如何确保使用 IAsyncCursor 返回的记录的顺序？我的集合中的纪元日期戳字段有一个升序索引，这足以保证排序顺序吗？。

=====================

FindAsync 方法返回一个 IAsyncCursor。记录以任意批次返回，这些批次使用以下 using/while 构造进行处理。

var collection = _database.GetCollection<BsonDocument>("restaurants");
var filter = new BsonDocument();
var count = 0;
using (var cursor = await collection.FindAsync(filter))
{
    while (await cursor.MoveNextAsync())
    {
        var batch = cursor.Current;
        foreach (var document in batch)
        {
            // What order will these records be in? how do I guarantee order ascending by epochtimestamp?;
        }
    }
}

是否会根据整个查询对每个异步“批次”进行排序？我如何保证记录的顺序正确？

epocdatestamp 字段的升序索引将允许我返回一个完整的排序列表（由于记录的数量需要很长时间）。

我是否应该按照我需要保证的顺序将完整的排序列表重写回数据库？这样未来的 IAsyncCursor 查询将按顺序返回记录。

我需要这样做吗？或者升序索引是否足够？

Answer 1

可以将排序添加到"FindOptions" 对象并作为参数提供给 FindAsync。在这种情况下，它是一个名为 epochtimestamp 的字段的升序排序。

只要你知道怎么做就很简单，

    var collection = _database.GetCollection<BsonDocument>("restaurants");
    var filter = new BsonDocument();
    var sort = Builders<BsonDocument>.Sort.Ascending("epochdatestamp");
    var options = new FindOptions<BsonDocument>
                  {
                    Sort = sort
                  };

    var count = 0;
    using (var cursor = await collection.FindAsync(filter, options))
    {
        while (await cursor.MoveNextAsync())
        {
            var batch = cursor.Current;
            foreach (var document in batch)
            {
                // process document
                count++;
            }
        }
    }