tornado-celery demo

gistfile1.txt

import tornado.ioloop
import tornado.web
import tasks

class AppHandler(tornado.web.RequestHandler):
    def get(self):
        self.write("test app")
        
class MainHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def get(self):
        result = tasks.s.delay("hello world")
        tornado.ioloop.IOLoop.instance().add_callback(self.on_result, result, callback)
        self.write("Hello, world")

    

    def on_result(self, result, callback):
        if result.ready():
            callback(result.result)
            self.finish()
        else:
            tornado.ioloop.IOLoop.instance().add_callback(self.on_result, result, callback)



def callback(s):
    print s

if __name__ == "__main__":
    application = tornado.web.Application([
    (r"/", MainHandler),
    (r"/app", AppHandler),
    ])
    application.listen(8001)
    tornado.ioloop.IOLoop.instance().start()