gistfile1.txt

/* == Imports == */
var AWS = require('aws-sdk');
var path = require('path');
var http = require('http');

var elasticsearch = require('elasticsearch');
var client = new elasticsearch.Client({
  host: 'search-guptadaniel-onk2zd5ibnyd646ohpu7tfmkv4.us-west-2.es.amazonaws.com',
  log: 'trace'
});


function getTestPersonaLoginCredentials(callback, context) {

    return http.get({
        host: 'https://api.instagram.com',
        path: '/v1/media/1213282857430725126_2942723755/comments?access_token=2942723755.2436505.fdda1ad9112f46caa0b1e2678bca97d2'
    }, function(response) {
        // Continuously update stream with data
        var body = '';
        response.on('data', function(d) {
            body += d;
        });
        response.on('end', function() {

            // Data reception is done, do whatever with it!
            var parsed = JSON.parse(body);
            var data = body.data;
            var usrArray = [];
            
            for(var i = 0; i < data.length ; i++ ) {
                var obj = {};

                obj['username'] = data[i].from.username;
                obj['text'] = data[i].text;

                usrArray.push({ create: { _index: 'test420', _type: 'json', _id: i*10 }});
                usrArray.push(obj); //fuck off
            }

            client.bulk({body: usrArray}, function (err, resp) {context.succeed(resp);});

            
        });
    });

},

exports.handler = function(event, context) {
    getTestPersonaLoginCredentials({},context)

};