def lambda_handler()

in Serverless Data Analytics Lab/lambda_function.py [0:0]


def lambda_handler(event, context):
    
    for record in event['records']:

        bytesArray = base64.b64decode(record['data'])
        my_json = bytesArray.decode('utf8').replace("'", '"')
        data = json.loads(my_json)
        payload = json.dumps(data)

        playerID = data["playerID"]
        wins = data["Wins"]
        losses = data["Losses"]
        timeplayed = data["TimePlayed"]
        caughtat = data["CaughtAt"]
        caughtby = data["CaughtBy"]

        response = cloudwatch.put_metric_data(
        MetricData = [
            {
                'MetricName': 'playerID',
                'Timestamp': datetime.datetime.now(),
                'Value': playerID,
                'StorageResolution': 1
            },
            {
                'MetricName': 'wins',
                'Timestamp': datetime.datetime.now(),
                'Value': wins,
                'StorageResolution': 1
            },
            {
                'MetricName': 'losses',
                'Timestamp': datetime.datetime.now(),
                'Value': losses,
                'StorageResolution': 1
            },
            {
                'MetricName': 'timePlayed',
                'Timestamp': datetime.datetime.now(),
                'Value': timeplayed,
                'StorageResolution': 1
            },
            {
                'MetricName': 'caughtAt',
                'Timestamp': datetime.datetime.now(),
                'Value': caughtat,
                'StorageResolution': 1
            },
            {
                'MetricName': 'CaughtBy',
                'Timestamp': datetime.datetime.now(),
                'Value': caughtby,
                'StorageResolution': 1
            },

        ],
        Namespace='serverless-analytics-demo'
        )