Export AWS Timestream table to JSON/CSV

gistfile1.txt

Create S3 Bucket
Create Kinesis Stream
Create Kinesis Firehose DeliveryStream
  Connect to Kinesis Stream
  Deliver to S3 Bucket
  Process with timestream-transformer

s3-ftp-uploader (lambda):
  events: using event bridge "Object Created" on above bucket
  main:
    decode bucket and key params from event
    data = s3api.getObject
    connect sftp
      put file(data)

timestream-transformer (lambda):
  main:
    recordmap = map event.records:
      payload = JSON.parse(record.data)
      return payload.toCSV()
    return recordmap

timestream-producer (lambda):
  schedule: rate(60 minutes)
  main:
    new KinesisProducer
    getLastTimestamp from DynamoDB
    SELECT * FROM timestreamTable WHERE time > getLastTimestamp
    foreach timestreamEntry:
      lastTimestamp = timestreamEntry.time
      kinesisProducter.putRecord(timestreamEntry)
    setLastTimestamp(lastTimestamp) in DynamoDB