simple doge json gateway

gateway.py

# coding: utf-8

import argparse

from gevent import monkey
monkey.patch_socket()

import logging
logging.basicConfig(level=logging.DEBUG)

from gevent.wsgi import WSGIServer
from doge.rpc.client import Cluster
from bottle import post, request, abort, app

global cluster


@post('/<service>/<method>')
def gateway(service, method):
    params = request.json
    if params is None:
        abort(400)
    global cluster
    try:
        client = cluster.get_client(service)
        res = client.call(method, *params)
        return {"errcode": 0, "errmsg": None, "result": res}
    except Exception as e:
        logging.exception('Error')
        return {"errcode": 1, "errmsg": str(e), "result": None}


if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('conf',
                        type=str,
                        help='doge client json config file path')
    args = parser.parse_args()
    logging.info('Init doge cluster from conf {}.'.format(args.conf))

    global cluster
    cluster = Cluster(args.conf)

    logging.info('Start doge gateway server.')

    WSGIServer(('', 8000), app()).serve_forever()