curena
9/1/2015 - 8:34 PM

AWS Lambda Activate a DataPipeline

AWS Lambda Activate a DataPipeline

console.log('Loading function');

var aws = require('aws-sdk');
var datapipeline = new aws.DataPipeline();

var pipeParams = {
  pipelineId: 'df-01839152MFDPDNMFTL32',
  //parameterValues: [
  //  {id: '', stringValue: ''},
  //  /* more items */
  //],
  //startTimestamp: new Date() || 'Wed Dec 31 1969 16:00:00 GMT-0800 (PST)' || 123456789
};

exports.handler = function(event, context) {
    console.log('Received event:', JSON.stringify(event, null, 2));
    datapipeline.activatePipeline(pipeParams, function(err, data) {
        if (err)
            console.log(err, err.stack); // an error occurred
        else    
            console.log(data);           // successful response
    });
};