From 06828b42cba79620593b46306221034f4b57a535 Mon Sep 17 00:00:00 2001 From: Andrew Date: Tue, 25 Mar 2025 12:54:07 +0000 Subject: [PATCH] [server]: Add return_punctuality_by_timestamp --- .../__init__.py | 0 .../lambda_function.py | 30 +++++++++++++++++++ 2 files changed, 30 insertions(+) create mode 100644 server/src/functions/return_punctuality_by_timestamp/__init__.py create mode 100644 server/src/functions/return_punctuality_by_timestamp/lambda_function.py diff --git a/server/src/functions/return_punctuality_by_timestamp/__init__.py b/server/src/functions/return_punctuality_by_timestamp/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/server/src/functions/return_punctuality_by_timestamp/lambda_function.py b/server/src/functions/return_punctuality_by_timestamp/lambda_function.py new file mode 100644 index 0000000..2359a4f --- /dev/null +++ b/server/src/functions/return_punctuality_by_timestamp/lambda_function.py @@ -0,0 +1,30 @@ +import json +import os +import boto3 +from boto3.dynamodb.conditions import Key, Attr + +os.environ.setdefault('AWS_DEFAULT_REGION', 'us-east-1') +dynamodb = boto3.resource('dynamodb') + +def lambda_handler(event, context): + table = dynamodb.Table("punctuality_by_timestamp") + + try: + items = [] + response = table.scan() + items.extend(response.get('Items', [])) + + while 'LastEvaluatedKey' in response: + response = table.scan(ExclusiveStartKey=response['LastEvaluatedKey']) + items.extend(response.get('Items', [])) + + return { + 'statusCode': 200, + 'body': json.dumps(items) + } + + except Exception as e: + return { + 'statusCode': 500, + 'body': json.dumps({'error': str(e)}) + }