def purge_log()

in microservices/storage_logging/main.py [0:0]


def purge_log():
    query = ds_client.query(kind='StorageLog')
    retain_limit = datetime.datetime.utcnow()-datetime.timedelta(minutes=3)
    query.keys_only()
    query.add_filter('timestamp', '<', retain_limit)
    for result in query.fetch():
        ds_client.delete(result.key)

    resp = {'message': 'succeeded.'}
    return resp, 200