jsonpour

A no-dependency streaming JSON parser. Based on JSONStream and jsonparse which were no longer maintained.

This is stripped down somewhat and uses more modern JS syntax.

Usage

npm install --save jsonpour

Examples

Listen for the data event:

import { createReadStream  } from 'node:fs'
import * as jsonpour from 'jsonpour'

const rs = createReadStream('./test.json')
// parse an incoming JSON doc looking for a results:[] array containing a 'doc' sub-object
rs.pipe(jsonpour.parse('results.*.doc')).on('data', function(obj) {
  console.log('Found a doc', obj)
}).on('finish', function() {
  console.log('done')
})

Piping:

import { createReadStream  } from 'node:fs'
import { Transform } from 'node:stream'
import * as jsonpour from 'jsonpour'

// streaming transform
const filter = new Transform({ objectMode: true })
filter._transform = function (obj, encoding, done) {
  // stringify the object
  this.push(JSON.stringify(obj) + '\n')
  done()
}

const rs = createReadStream('./test.json')
// stream every object from the results array via a filter to stdout
rs.pipe(jsonpour.parse('results.*'))
  .pipe(filter)
  .pipe(process.stdout)