tornado HTTP server for solariat_nlp.classify_content

classify_content_server.py

#!/usr/bin/python

import json
import tornado.gen
import tornado.ioloop
import tornado.web
from futures import ProcessPoolExecutor
from solariat_nlp import classify_content

def do_work(msg):
    return json.dumps(classify_content(msg))


class MainHandler(tornado.web.RequestHandler):

    pool = ProcessPoolExecutor()

    @tornado.gen.coroutine
    def post(self):
        msg = self.request.body
        result = yield self.pool.submit(do_work, msg)
        self.write(result)


application = tornado.web.Application([
    (r'/', MainHandler),
])

classify_content("test") # warm-up cache

application.listen(8888)
tornado.ioloop.IOLoop.instance().start()