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