in source/helper/lib/kinesisapp-helper.js [41:83]
kinesisAnalyticsAppHelper.prototype.startApplication = function(ApplicationName, cb) {
console.log(['Looking up Kinesis Data Analytics application:', ApplicationName].join(' '));
var params = {
ApplicationName: ApplicationName
};
ka.describeApplication(params, function(err, app_description) {
if (app_description == null) {
console.log(['Could not find application:', ApplicationName].join(' '));
return cb(['Kinesis Data Analytics application,', ApplicationName, ', could not be found!'].join(' '), null);
}
console.log('app status: ',app_description.ApplicationDetail.ApplicationStatus);
if (err) {
console.log(['Failed to describe application:', err].join(' '));
return cb(err, null);
} else {
if (app_description.ApplicationDetail.ApplicationStatus === 'READY') {
//Start App
params = {
ApplicationName: ApplicationName,
InputConfigurations: [
{
'Id': '1.1',
'InputStartingPositionConfiguration': {
'InputStartingPosition': 'NOW'
}
}
]
};
console.log("Starting application");
ka.startApplication(params, function(err, response) {
if (err) {
console.log(['Failed to start application', item.ApplicationName, ': ', err].join(' '));
return cb(err, null);
} else {
return cb(null, "SUCCESS");
}
});
} else {
return cb(['Kinesis Data Analytics Application was not in READY state (app status === ', app_description.ApplicationDetail.ApplicationStatus,')'].join(''), null);
}
}
});
};