example lambda function

lambda_function.py

import json
import boto3
import base64
from datetime import datetime
import requests


def lambda_handler(event, context):

    for record in event['Records']:
        decoded_data = json.loads(base64.b64decode(record['kinesis']['data']))

        user_id = decoded_data['user_id']
        amount = decoded_data['amount']

        dynamo_client = boto3.client('dynamodb')

        put_response = dynamo_client.put_item(
            TableName='user_spending',
            Item={
                'user_id': {'S': user_id}, 
                'amount': {'N': f'{amount}'},
                'updated_at': {'S': datetime.utcnow().isoformat()}
            }
        )

        if put_response['ResponseMetadata']['HTTPStatusCode'] == 200:
            message = {'success': True, 'msg': f'success processing event: user_id: {user_id} amount: {amount}'}

        else:
            raise RuntimeError(f'failure processing event: user_id: {user_id} amount: {amount}')

        return message