4

我正在尝试将来自 Formidable 的上传直接流式传输到 Mongo 的 GridFS。

在写入任何数据之前需要打开 GridStore，但是在打开存储所需的时间内，已经有太多数据未解析并且失败。

如何准备 GridStore 然后处理传入的上传？

function upload (request, response, next, options) {
    var form = new Formidable.IncomingForm();

    var store = new Mongo.GridStore(options.mongoose.connection.db, new ObjectID, 'w+', {
        root: 'store',
        chunk_size: 1024 * 64
    } );

    form.onPart = function (part) {
        if(!part.filename){
            form.handlePart(part);
            return;
        }

        part.on('data', function(buffer){
            store.write(buffer);
        });

        part.on('end', function() {
            store.close();
        });
    };

    store.open( function (error, store) {
        form.parse(request);
    });

    response.send();
}
4

2 回答 2

3

由于打开 GridStore 文件是异步的，而强大的不是，因此您需要在等待 GridStore 文件打开时对强大的传入流进行一些手动缓冲。由于 GridFS 无法通过管道传输给您，因此您需要在打开后手动将每个缓冲块写入 GridStore。

刚刚发布gridform的应该可以满足您的需求。

https://github.com/aheckmann/gridform

于 2012-05-07T18:05:08.577 回答
1

您可以将表单的处理代码移动到store.open回调中，例如：

function upload (request, response, next, options) {

    var store = new Mongo.GridStore(options.mongoose.connection.db, new ObjectID, 'w+', {
        root: 'store',
        chunk_size: 1024 * 64
    } );


    store.open( function (error, store) {
        var form = new Formidable.IncomingForm();
        form.onPart = function (part) {
            if(!part.filename){
                form.handlePart(part);
                return;
            }

            part.on('data', function(buffer){
                store.write(buffer);
            });

            part.on('end', function() {
                store.close();
            });
        };
        form.parse(request);
    });

    response.send();
}
于 2012-07-21T16:18:19.570 回答