How to use the KinesisAnalytics function from aws-sdk

Find comprehensive JavaScript aws-sdk.KinesisAnalytics code examples handpicked from public code repositorys.

10
11
12
13
14
15
16
17
18
19

if (!program.name) {
    return console.error('Missing application name, use -N or --name\n');
}

const kinesisanalytics = new AWS.KinesisAnalytics({region: program.region});

(function runCommand() {

    return Promise.resolve()
fork icon21
star icon106
watch icon3

108
109
110
111
112
113
114
115
116
117
      CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "TEMP_STREAM" SELECT STREAM "ts","val", "trip_id", "vin", ("val"-250) as ANOMALY_SCORE FROM "SOURCE_SQL_STREAM_001" WHERE "name" = \'oil_temp\';\r\n\
      CREATE OR REPLACE PUMP "ANOMALY_STREAM_PUMP" AS INSERT INTO "ANOMALY_STREAM" SELECT STREAM * FROM "TEMP_STREAM";\r\n\
      CREATE OR REPLACE PUMP "OUTPUT_PUMP" AS INSERT INTO "ANOMALY_OUTPUT_STREAM" SELECT STREAM *,\'oil_temp\' as telemetric, 250 as low_limit FROM "TEMP_STREAM" WHERE ANOMALY_SCORE > 30;\r\n'
};

let kinesisAnalytics = new AWS.KinesisAnalytics();
kinesisAnalytics.createApplication(_params, function(err, data) {
    if (err) {
        console.log(err);
        console.log('Could not create Amazon Kinesis Analytics application');
fork icon55
star icon84
watch icon29

+ 5 other calls in file