process_anomalies.py

import base64
import json
import boto3

snsClient = boto3.client('sns')
print('Loading function')

def lambda_handler(event, context):
    for record in event['Records']:
        # Kinesis data is base64 encoded so decode here
        # payload = json.loads(base64.b64decode(record['kinesis']['data']))
        payload = base64.b64decode(record['kinesis']['data'])
        print payload
        response = snsClient.publish(
            TopicArn='arn:aws:sns:us-east-1:964214137428:heartanomalies',
            Message='A possible heart anomaly was detected. Are you ok?' + payload + '\nClick here to let us know:\n http://heartnotification.com',
            Subject='Anomaly detected',
            MessageStructure='string',
            MessageAttributes={
            'String': {
                'DataType': 'String',
                'StringValue': 'New records have been processed.'
                }
            }
        )
    return 'Successfully processed {} records.'.format(len(event['Records']))