def retrieve()

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