mikeapted

create external schema YourInitial_bigdata from data catalog 
database 'YourInitial_bigdata'
iam_role 'Role ARN Copied in Step 12'
region 'us-east-1';

mikeapted

select sensorname, sensorvalue, anomalyscore from YourInitial_bigdata.analytic_csv2parquet where anomalyscore > 2 limit 10;

mikeapted

select sensorname, sensorvalue, anomalyscore from analytic_csv2parquet where anomalyscore > 2 limit 10

mikeapted

CREATE OR REPLACE STREAM "TEMP_STREAM" (
   "sensorName"        varchar (40),
   "sensorValue"   integer,
   "ANOMALY_SCORE"  DOUBLE);
-- Creates an output stream and defines a schema
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
   "sensorName"       varchar(40),
   "sensorValue"       integer,
   "ANOMALY_SCORE"  DOUBLE,
   "created" TimeStamp);

mikeapted

import json
import datetime
import random
import boto3

kinesis = boto3.client('kinesis', region_name='us-east-1') #<--- change region if not in N.Virginia

def getData(sensorType, sensorName, lowVal, highVal):
    data = {}
    data['sensorType'] = sensorType

mikeapted

Resources:
  ScaleUpPolicy:
    Type: AWS::AutoScaling::ScalingPolicy
    Properties:
      AdjustmentType: ChangeInCapacity
      AutoScalingGroupName:
        Ref: AWSEBAutoScalingGroup
      Cooldown: '1'
      ScalingAdjustment: '1'
  ScaleDownPolicy:

mikeapted

Sessions

Code	Title	Duration	Link
Keynote	Andy Jassy Keynote Announcement Recap	0:01	https://www.youtube.com/watch?v=TZCxKAM2GtQ
Keynote	AWS re:Invent 2016 Keynote: Andy Jassy	2:22	https://www.youtube.com/watch?v=8RrbUyw9uSg
Keynote	AWS re:Invent 2016 Keynote: Werner Vogels	2:16	https://www.youtube.com/watch?v=ZDScBNahsL4
Keynote	[Tuesday Night Live with Jame