kinesisAnalyticsAppHelper.prototype.startApplication = function()

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