Stream example

npm2csvgz.js

var request  = require('request')
  , json     = require('JSONStream')
  , through2 = require('through2')
  , csv      = require('csv-write-stream')
  , zlib     = require('zlib')
  , fs       = require('fs')

request({url: 'https://registry.npmjs.org/-/all'})
  .pipe(json.parse('*'))
  .pipe(through2.obj(function (data, enc, callback) {
    if (data.name && data.description)
      this.push({ name: data.name, description: data.description })
    callback()
  }))
  .pipe(csv({ headers: [ 'name', 'description' ] }))
  .pipe(zlib.createGzip())
  .pipe(fs.createWriteStream('npm.csv.gz'))