Range Service Poller Lambda - DynamoDB Util

Code

lambdas.utils.dynamodb_util.last_event_id(config_details: dict, event_type: str)

This function is used to get last_event_id(watermark) from dynamo_db_table to process further

Parameters

• event_type – This argument is used for reding data from dynamoDB table value is

• config_details – config details

Returns: get last event id

lambdas.utils.dynamodb_util.update_last_event(config_details, event_entity: str, last_event_id: str, updated_timestamp: str)

This function is used to update the watermark dynamodb table with last event id from range v1 API call.

Parameters

• config_details – config details

• event_entity – ‘range’ or ‘space’ events

• last_event_id – last event id to update in dynamoDb table

• updated_timestamp – time stamp to update