2016-04-01 4 views
1

Dies ist meine erste gridfs-stream Arbeit. Ich versuche eine Datei aus meinem lokalen Verzeichnis zu lesen (C: \ work \ node \ test.txt) und schreibe sie in gridfs-stream. Wenn ich diese Datei ausführen, bekomme ich unter FehlerMongo gridfs-stream

C: \ Arbeit \ Knoten> Knoten Test events.js: 85 Throw Er; // Nicht behandelte 'Fehler' Ereignis ^ Fehler: ENOENT, offen 'C: \ work \ Knoten \ work ode est.txt' bei Error (nativ)

Ich habe versucht, auch versuchen, Beifang zu verwenden, aber hatte den gleichen Fehler. Kann jemand den Fehler sehen, den ich mache und darauf hinweisen? Vielen Dank.

und hier ist mein Code ..

var fs = require("fs"), 
    mongo = require("mongodb"), 
    Grid = require("gridfs-stream"), 
    gridfs, 
    writeStream, 
    readStream, 
    buffer = ""; 

    mongo.MongoClient.connect("mongodb://localhost:27017/test", function (err, db) { 
    // "use strict"; 
    gridfs = Grid(db, mongo); 

    // write file 
    writeStream = gridfs.createWriteStream({ filename: "test.txt" }); 
    fs.createReadStream("C:\work\node\test.txt").pipe(writeStream); 
    }); 
+1

Ok. Ich habe die Escape-Zeichen in meinem Dateipfad nicht erkannt. Sobald ich es korrigiert habe, funktioniert es. Ich glaube, ich habe die Waffen zu früh gesprungen :) – JBone

+0

So sieht mein korrigierter Dateipfad aus fs.createReadStream ("C: \/work \/node \ /test.txt"). Pipe (writeStream); – JBone

+0

sollten Sie es als Antwort und akzeptieren Sie es selbst. könnte jemand anderem helfen :) – war1oc

Antwort

0

Dies funktioniert nun mit der Pfaddatei korrigiert

var fs = require("fs"), 
    mongo = require("mongodb"), 
    Grid = require("gridfs-stream"), 
    gridfs, 
    writeStream, 
    readStream, 
    buffer = ""; 

    mongo.MongoClient.connect("mongodb://localhost:27017/test", function (err, db) { 
// "use strict"; 
    gridfs = Grid(db, mongo); 

    // write file 
    writeStream = gridfs.createWriteStream({ filename: "test.txt" }); 
    **fs.createReadStream("C:\/work\/node\/test.txt").pipe(writeStream);** 
});