How to initiate tasks in celery to request a webcam in a tornado?

Question

I am currently using a software stack like: Tornado (Websockethandler) + Celery (task manager) + RabbitMQ (amqp) + Redis as a backend.

However, I cannot integrate Tornado and celery for websocket requests. Can we have some pointers / examples for this?

Note. I used CeleryMixin and Tcelery. Not working well for me.

Thanks in advance

Answer 1

https://github.com/mher/tornado-celery lets you name Celery tasks from Tornado

from tornado import gen, web
import tcelery, tasks

tcelery.setup_nonblocking_producer()

class AsyncHandler(web.RequestHandler):
    @asynchronous
    def get(self):
        tasks.echo.apply_async(args=['Hello world!'], callback=self.on_result)

    def on_result(self, response):
        self.write(str(response.result))
        self.finish()