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()
21
106
3
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');
55
84
29
+ 5 other calls in file
aws-sdk.S3 is the most popular function in aws-sdk (7245 examples)