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
});
};