in CWMetricsToOpenSearch/handler.py [0:0]
def get_last_timestamp_ddb(domain_name, region):
ddb = boto3.client('dynamodb')
try:
ret = ddb.get_item(TableName=DDB_TABLE,
Key={'domain': {'S': domain_name},
'region': {'S': region}})
if not ret or not ret.get('Item', None):
return None
iso_ts = ret['Item'].get('Timestamp', None)
if not iso_ts:
return None
iso_ts = iso_ts['S']
return parser.parse(iso_ts)
except Exception as e:
print('Exception retrieving timestamp for "{}:{}"'.format(domain_name, region))
print(e)
return None