Skip to content

Instantly share code, notes, and snippets.

@codepreneur

codepreneur/indexAccountsToCloudsearch.js

Forked from ryanfitz/indexAccountsToCloudsearch.js
Created August 1, 2016 22:56
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save codepreneur/8a13296b174b33f46d279f5b3cb2ab26 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save codepreneur/8a13296b174b33f46d279f5b3cb2ab26 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @ryanfitz ryanfitz created this gist Jul 17, 2015.
    35 changes: 35 additions & 0 deletions indexAccountsToCloudsearch.js
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,35 @@
    var AWS = require('aws-sdk');

    exports.handler = function(event, context) {
    var cloudsearchdomain = new AWS.CloudSearchDomain({endpoint: 'doc-dev-cinch-accounts-ltmqj5gt5mjb5hg5eyqaf2v5hu.us-east-1.cloudsearch.amazonaws.com'});

    var documents = event.Records.map(function(record) {
    var data = {id : record.dynamodb.Keys.id.S};

    if (record.eventName === 'REMOVE') {
    data.type = 'delete'
    } else {
    var image = record.dynamodb.NewImage;

    data.type = 'add'
    data.fields = {
    name : image.name.S,
    username : image.username.S,
    email : image.email.S
    };
    }

    return data;
    });

    var params = {contentType: 'application/json', documents : JSON.stringify(documents) };
    console.log('uploading documents to cloudsearch domain', params);
    cloudsearchdomain.uploadDocuments(params, function(err, data) {
    if(err) {
    console.log('Error uploading documents to cloudsearch', err, err.stack);
    context.fail(err);
    } else {
    context.succeed("Successfully processed " + event.Records.length + " records.");
    }
    });
    };