【发布时间】:2019-04-29 12:15:58
【问题描述】:
我能够使用 GridFSBucket 的 openDownloadStream 上传文件,并看到该文件已上传并在 song.files 块下可见。但是由于某种原因,尝试下载时出现以下错误-
Caught exception: Error: FileNotFound: file def1.txt was not found
我的代码是 -
var express = require('express');
var gridModule = express.Router();
var mongoose = require('mongoose');
var fs = require('fs');
gridModule.post('/', (req, res) => {
console.log("::::grid");
//const gridfs = new mongoose.mongo.GridFSBucket(mongoose.connection.db);
//const writeStream = gridfs.openUploadStream('test.dat');
var gridfs = new mongoose.mongo.GridFSBucket(mongoose.connection.db, {
chunkSizeBytes: 1024,
bucketName: 'songs'
});
fs.createReadStream('./def.txt').
pipe(gridfs.openUploadStream('def1.txt')).
on('error', function (error) {
assert.ifError(error);
}).
on('finish', function () {
console.log('done!');
process.exit(0);
});
});
gridModule.get('/', (req, res) => {
var gridfs = new mongoose.mongo.GridFSBucket(mongoose.connection.db, {
chunkSizeBytes: 1024,
bucketName: 'songs'
});
/* var bucket = new mongodb.GridFSBucket(db, {
chunkSizeBytes: 1024,
bucketName: 'songs'
}); */
gridfs.openDownloadStream('def1.txt').
pipe(fs.createWriteStream('./def1.txt')).
on('error', function(error) {
console.log(":::error");
assert.ifError(error);
}).
on('finish', function() {
console.log('done!');
process.exit(0);
});
});
module.exports = gridModule;
我也尝试过使用 ObjectId id,但同样的错误。有人猜到我在这里做错了什么吗?
注意 - 这里的代码似乎没有像两次声明存储桶那样优化,请暂时忽略它,因为一旦它工作我会更正它。
【问题讨论】:
标签: node.js mongodb mongoose filestream gridfs