justinsoliz

// applications/kinesis_streamer/lib/handler.js

import AWS from 'aws-sdk';
const kinesis = new AWS.Kinesis();

export function receiveEvent(event, context, callback) {
  console.log('demoHandler');
  console.log(`Event: ${JSON.stringify(event, null, 2)}`);
  console.log(`Context: ${JSON.stringify(context, null, 2)}`);
  const base64Data = event.Records[0].kinesis.data;

redacted

class State:
    def __init__(self):
        pass

    def import_position(self):
        self.position = {x: x * x for x in range(10)}

    def __getattr__(self, s):
        try:
            return self.__getattribute__(s)