We proceed with the recipe as follows:
- In the 10/04 folder is an api.py file that implements a modified Flask-RESTful API from earlier, but with several modifications. Let's examine the code of the API:
from flask import Flaskfrom flask_restful import Resource, Apifrom elasticsearch import Elasticsearchfrom nameko.standalone.rpc import ClusterRpcProxyapp = Flask(__name__)api = Api(app)CONFIG = {'AMQP_URI': "amqp://guest:guest@rabbitmq"}class JobListing(Resource): def get(self, job_listing_id): print("Request for job listing with id: " + job_listing_id) es = Elasticsearch(hosts=["elastic"]) if (es.exists(index='joblistings', doc_type='job-listing', id=job_listing_id)): print('Found the document in Elasticsearch') doc = es.get( ...