| import black_cherry_bootstrap |
| import requests |
| from bottle import route, run, template, get, debug, static_file, request, response |
| |
| debug(True) |
| http_header = { "content-type": "application/json" } |
| |
| # Core Routing |
| @route('/') |
| def jsontest(): |
| return template('cherry') |
| |
| @route('/static/<filename:path>') |
| def send_static(filename): |
| return static_file(filename, root='static') |
| |
| # API Helpers |
| def build_response(endpoint, data): |
| api_endpoint = "http://localhost:19002/" + endpoint |
| response = requests.get(api_endpoint, params=data, headers=http_header) |
| try: |
| return response.json(); |
| except ValueError: |
| return [] |
| |
| # API Endpoints |
| @route('/query') |
| def run_asterix_query(): |
| return (build_response("query", dict(request.query))) |
| |
| @route('/query/status') |
| def run_asterix_query_status(): |
| return (build_response("query/status", dict(request.query))) |
| |
| @route('/query/result') |
| def run_asterix_query_result(): |
| return (build_response("query/result", dict(request.query))) |
| |
| |
| @route('/ddl') |
| def run_asterix_ddl(): |
| return (build_response("ddl", dict(request.query))) |
| |
| @route('/update') |
| def run_asterix_update(): |
| return (build_response("update", dict(request.query))) |
| |
| res = black_cherry_bootstrap.bootstrap() |
| run(host='localhost', port=8080, debug=True) |