MongoError при загрузке файла с использованием mongoose, gridfs-stream и multer

Проблема заключается в том, что вы не просто передаете запрос файла в gridfs-stream. Использование Multer в качестве промежуточного ПО для перехвата любого multipart/form-data почтового запроса. По мере поступления потока Multer (созданный на основе Busboy) отслеживает события on('field') и on('file') и анализирует их соответствующим образом. То, что вы передаете Мултеру, — это не просто файл.

Этот фрагмент кода работает нормально, потому что Multer действительно проанализировал для вас req.files и req.body к этому моменту:

   // Create a gridfs-stream
   var gfs = new Gridfs(db, mongoDriver);

   var file = req.files.myFile;

   var fileId = new ObjectId();

   console.log("Creating WriteStream");
   var writeStream = gfs.createWriteStream({
        _id: fileId,
        filename: file.originalname,
        mode: 'w',
        content_type: file.mimetype,
        metadata: {
            id: '123',
            number: '2',
            name: "Kenny Erasmuson"
        }
     });
     console.log("Created WriteStream");

Но где ваш код сталкивается с проблемами, здесь по причинам, упомянутым выше:

 req.pipe(writeStream);

Мне еще предстоит найти способ потоковой передачи запроса на публикацию multipart/form-data с более чем простой загрузкой файлов прямо в GridFS. Если ваш почтовый запрос не содержит ничего, кроме файла (имеется в виду отсутствие других полей ввода html в форме), вы можете рассмотреть возможность удаления Multer из промежуточного программного обеспечения, по крайней мере, для этого маршрута.

Для моего варианта использования мне требуется возможность получать сообщение в форме html с текстовыми входами вместе с загрузкой файла (я сохраняю метаданные о файле при загрузке). Вот как я добился того, что мне было нужно с Multer:

var uploadImg = function(req,res) {
      var writestream = gfs.createWriteStream({
        filename: req.files.file.name,
        mode:'w',
        content_type:req.files.file.mimetype,
        metadata:req.body,
      });
    fs.createReadStream(req.files.file.path).pipe(writestream);

    writestream.on('close', function (file) {
        res.send("Success!");
        fs.unlink(req.files.file.path, function (err) {
          if (err) console.error("Error: " + err);
          console.log('successfully deleted : '+ req.files.file.path );
        });
    });

};

По умолчанию Multer сохраняет ваши файлы на диске. Одним из быстрых решений является просто создать поток чтения и передать его обратно в GridFS. После завершения записи удалите файл tmp.

В качестве примечания: похоже, бытует мнение, что лучше всего использовать Multer в качестве промежуточного программного обеспечения только на тех маршрутах, которые в нем нуждаются. Вы можете прочитать больше об этой мысли в последнем разделе этого.

Обновлять

Я думаю, что я близок к тому, чтобы найти способ прямой потоковой передачи с метаданными GridFS с помощью Skipper. . Я сейчас выясняю, не могу ли я получить некоторые обновления для skipper-gridfs. который будет принимать текстовые входы в форме html и устанавливать их как метаданные и т. д. Настройка skipper-gridfs кажется довольно незначительной. Я обновлю, когда это будет смыто. Если вы посмотрите на шкипера, убедитесь, что вы понимаете, что порядок ввода вашей html-формы (если он у вас есть) имеет значение.

В моем коде:

var fileId = new ObjectId();

console.log("Creating WriteStream");
var writeStream = gfs.createWriteStream({
    _id: fileId,
    filename: file.originalname,
    mode: 'w',
    content_type: file.mimetype,
    metadata: {
        id: '123',
        number: '2',
        name: "Kenny Erasmuson"
    }
 });

Я назначаю ObjectId, а не строковое представление ObjectId свойству _id объекта, переданному в gfs.createWriteStream. Оказывается, это вызывает MongoError в моем коде.

Исправление, обнаруженное здесь, чтобы изменить строку кода, вызывающую проблему:

_id: fileId.str,

Сделав это, я столкнулся с проблемой, что файл не помещается в коллекцию fs.chunks mongodb, хотя метаданные попадают в коллекцию fs.files mongodb. Ответ AddieD здесь начинает решать эту проблему :)