zenon/dse-assignment
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add event store connection

Browse Source
This commit is contained in:
David Eder 2021-06-09 22:15:42 +02:00
parent b9c450cedc
commit 5d337d6d25
2 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
components/x_way/requirements.txt
View File

@ -1,2 +1,3 @@
flask flask
Flask-Cors Flask-Cors
requests

18
components/x_way/x_way_server.py
View File

@ -2,11 +2,14 @@ import requests
from bson import json_util from bson import json_util
from flask import Flask from flask import Flask
from flask_cors import CORS from flask_cors import CORS
from flask import request
import json;
app = Flask(__name__) app = Flask(__name__)
CORS(app) CORS(app)
ENTITY_IDENT_URL = 'http://entityident:5002/api/v1/resources/' ENTITY_IDENT_URL = 'http://entityident:5002/api/v1/resources/'
EVENT_STORE_URL = 'http://eventstore:5001/api/keys/'
@app.route('/') @app.route('/')
@ -14,6 +17,21 @@ def hello_world():
return 'Hello World' return 'Hello World'
@app.route('/api/v1/resources/car_events', methods=['GET'])
def get_cars_events():
vin = request.args.get('vin')
try:
response = requests.get(EVENT_STORE_URL + 'DAF:' + vin + '/')
cars = json.loads(response.text)
except requests.exceptions.ConnectionError as e:
print("Is the EVENT_STORE_URL running and reachable?")
raise e
return json_util.dumps({'cursor': cars})
@app.route('/api/v1/resources/cars', methods=['GET']) @app.route('/api/v1/resources/cars', methods=['GET'])
def get_cars(): def get_cars():