in microservices/message_board/main.py [0:0]
def retrieve():
json_data = request.get_json()
name = None
if 'name' in json_data.keys():
name = json_data['name']
if name is None:
resp = {'message': 'name property is required.'}
return resp, 500
query = ds_client.query(kind='Message') # Create a query object for kind 'Message'.
query.add_filter('name', '=', name) # Add a filter condition.
query.order = ['timestamp'] # Add a sort condition.
messages = []
for result in query.fetch(): # Iterate over the query result.
messages.append(
{
'message': result['message'],
'timestamp': result['timestamp']
}
)
resp = {
'name': name,
'messages': messages
}
return resp, 200