so erstellen Sie eine readstream mit einem Puffer mit nodejs

Habe ich diese json: 

var myJSON = '{"kind": "person", "fullName": "Rivka3"}';

Ich versuche, uploed es zu bigquery, mit createReadStream.
wenn ich speichern Sie es lokal, die ich erfolgreich:

fs.writeFile("/tmp/bq_json_file_new.json", myJSON, function(err){});
fs.createReadStream("/tmp/bq_json_file_new.json")
  .pipe(table.createWriteStream(metadata))
  .on('complete', function(job) {
    job
      .on('error', console.log)
      .on('complete', function(metadata) {
        console.log('job completed', metadata);
      });
  });

jetzt versuche ich, dies zu tun, ohne es zu speichern localy - mit Hilfe eines Puffers:

fs.createReadStream(new Buffer(myJSON, "utf8"))
  .pipe(table.createWriteStream(metadata))
  .on('complete', function(job) {
    job
      .on('error', console.log)
      .on('complete', function(metadata) {
        console.log('job completed', metadata);
      });
  });

aber ich erhalte diese Fehlermeldung:

fs.js:575
  binding.open(pathModule._makeLong(path),

TypeError: path must be a string
InformationsquelleAutor dina | 2016-06-15
  1. 18

    mit stream löst das problem:

    var stream = require('stream');

var bufferStream = new stream.PassThrough();

bufferStream.end(new Buffer(myJSON));

bufferStream.pipe(table.createWriteStream(metadata))
                   .on('complete', function(job) {
                     job
                       .on('error', console.log)
                       .on('complete', function(metadata) {
                         console.log('job completed', metadata);
                       });
                   });
    • createWriteStream speichert diese wieder lokal!!!!
    InformationsquelleAutor dina
Schreibe einen Kommentar