aindreas/fyp
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[server]: Makre return_transient_data treat timestamps as numbers

Browse Source
This commit is contained in:
Aindréas Ó hAodha
2025-03-24 22:13:40 +00:00
parent c54e06805d
commit 96611d58d5
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/functions/return_transient_data/lambda_function.py
View File

@ -69,28 +69,28 @@ def lambda_handler(event, context):
if object_types: if object_types:
response = table.scan( response = table.scan(
FilterExpression=Attr('objectType').is_in(object_types) & Attr('timestamp').eq(str(newest_timestamp)) FilterExpression=Attr('objectType').is_in(object_types) & Attr('timestamp').eq(newest_timestamp)
) )
items_with_latest_timestamp.extend(response.get('Items', [])) items_with_latest_timestamp.extend(response.get('Items', []))
# Handle pagination if necessary # Handle pagination if necessary
while 'LastEvaluatedKey' in response: while 'LastEvaluatedKey' in response:
response = table.scan( response = table.scan(
FilterExpression=Attr('objectType').is_in(object_types) & Attr('timestamp').eq(str(newest_timestamp)), FilterExpression=Attr('objectType').is_in(object_types) & Attr('timestamp').eq(newest_timestamp),
ExclusiveStartKey=response['LastEvaluatedKey'] ExclusiveStartKey=response['LastEvaluatedKey']
) )
items_with_latest_timestamp.extend(response.get('Items', [])) items_with_latest_timestamp.extend(response.get('Items', []))
else: else:
# Scan the entire table for the latest timestamp if no object types are specified # Scan the entire table for the latest timestamp if no object types are specified
response = table.scan( response = table.scan(
FilterExpression=Attr('timestamp').eq(str(newest_timestamp)) FilterExpression=Attr('timestamp').eq(newest_timestamp)
) )
items_with_latest_timestamp.extend(response.get('Items', [])) items_with_latest_timestamp.extend(response.get('Items', []))
# Handle pagination if necessary # Handle pagination if necessary
while 'LastEvaluatedKey' in response: while 'LastEvaluatedKey' in response:
response = table.scan( response = table.scan(
FilterExpression=Attr('timestamp').eq(str(newest_timestamp)), FilterExpression=Attr('timestamp').eq(newest_timestamp),
ExclusiveStartKey=response['LastEvaluatedKey'] ExclusiveStartKey=response['LastEvaluatedKey']
) )
items_with_latest_timestamp.extend(response.get('Items', [])) items_with_latest_timestamp.extend(response.get('Items', []))