Twitter Streaming API を td へ流し込む

twit_streaming_to_td_sample.js

/*jslint indent: 4*/
/*jslint node: true */
'use strict';

var Twitter = require('ntwitter'),
    logger = require('fluent-logger');
logger.configure('td.test_db', {host: 'localhost', port: 24224});

var twit = new Twitter({
    consumer_key: 'XXX',
    consumer_secret: 'XXX',
    access_token_key: 'XXX',
    access_token_secret: 'XXX',
});

twit.stream('statuses/filter', {'track': 'javascript'}, function (stream) {
    stream.on('data', function (data) {
        logger.emit('javascript', data);
    });
});