blat lines from newline-separated JSON into redis for logstash to eat

blat.js

#!/usr/bin/env node

// usage:
// blat.js &
// logstash agent -f inhale-all-seen.conf &

'use strict';

var fs = require('fs'),
    redis = require('redis'),
    split = require('split'),
    stream = require('stream');

var client = redis.createClient(),
    pusher = new stream.Writable(),
    count = 0;

pusher._write = function write(chunk, encoding, callback) {
    chunk = chunk.toString();
    if ((++count % 1000) === 0) {
        process.stderr.write(count + '\r');
    }
    client.rpush('all-seen', chunk.trim(), callback);
};

fs.createReadStream('./all-seen.log')
    .setEncoding('utf-8')
    .pipe(split())
    .pipe(pusher);