pipe（）数据到Json文件或Postgrsql

我有这个代码：

var MetaUtil = require('osm-meta-util'); var meta = MetaUtil({ 'delay': 1000, 'start': '000598424', //file number 'end': '001122000' //file number }).pipe(process.stdout) //outputs to console 

我怎样才能输出到Json文件，所以我可以以后上传到Postgresql数据库。

带着敬意

安德烈

Answer 1

创build一个文件可写的stream和pipe道数据：

 var fs = require('fs'); var file = fs.createWriteStream('./output.json') MetaUtil({ 'delay': 1000, 'start': '000598424', //file number 'end': '001122000' //file number }).pipe(file); 

反过来，使用可读的stream来读取文件中的数据，并根据您使用的数据库框架将其插入到数据库中。

我不熟悉postres，但pg-copy-streams似乎是为它提供了这个function：

 var fs = require('fs'); var pg = require('pg'); var copyFrom = require('pg-copy-streams').from; pg.connect(function(err, client, done) { var stream = client.query(copyFrom('COPY my_table FROM STDIN')); var fileStream = fs.createReadStream('some_file.tsv') fileStream.on('error', done); fileStream.pipe(stream).on('finish', done).on('error', done); });