def get_last_timestamp_ddb()

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