asterix-examples/src/main/resources/black-cherry/run_black_cherry.py

import black_cherry_bootstrap
from urllib2 import URLError, urlopen
from urllib import urlencode
from json import loads, dumps
from bottle import route, run, template, static_file, request

# 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

    try:
        # Encode data into url string
        urlresponse = urlopen(api_endpoint + '?' + urlencode(data))

        # There are some weird bits passed in from the Asterix JSON. 
        # We will remove them here before we pass the result string 
        # back to the frontend.
        urlresult = ""
        CHUNK = 16 * 1024
        while True:
            chunk = urlresponse.read(CHUNK)
            if not chunk: break
            urlresult += chunk
        
        # QUERY ISSUE 2: UNCOMMENT THIS TO SEE WEIRD BUG    
        urlresult = ','.join(urlresult.split(']}{"results":['))

        # Create JSON dump of resulting response 
        return loads(urlresult)

    except ValueError, e:
        pass

    except URLError, e:

        # Here we report possible errors in request fulfillment.
        if hasattr(e, 'reason'):
            print 'Failed to reach a server.'
            print 'Reason: ', e.reason

        elif hasattr(e, 'code'):
            print 'The server couldn\'t fulfill the request.'
            print 'Error code: ', e.code

# 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)