Product Service Poller Lambda - DynamoDB Util¶
Code¶
- lambdas.utils.dynamodb_util.last_event_id(config_details: dict)[source]¶
This function is used to get last_event_id(watermark) from dynamo_db_table to process further
- Parameters
config_details – config details
Returns: get last event id
- lambdas.utils.dynamodb_util.update_last_event(config_details, last_event_id: str, updated_timestamp: str)[source]¶
This function is used to update the watermark dynamodb table with last event id from product v1 API call.
- Parameters
config_details – config details
last_event_id – last event id to update in dynamoDB table
updated_timestamp – time stamp to update