class AsyncHandler(tornado.web.RequestHandler):
@tornado.web.asynchronous
def get(self):
tasks.sleep.apply_async(args=[5], callback=self.on_result)
def on_result(self, response):
self.write(str(response.result))
self.finish()
引发错误:
raise TypeError(repr(o) + " is not JSON serializable")
TypeError: <bound method AsyncHandler.on_result
of <__main__.AsyncHandler object at 0x10e7a19d0>> is not JSON serializable
经纪人和后端都使用 redis,我只是从https://github.com/mher/tornado-celery
当我使用 amqp 代理和 redis 后端时,它运行良好,但在使用 redis 代理时则不然。这是因为龙卷风异步不支持 redis 代理吗?
文档说:
注意:目前回调仅适用于 AMQP 和 Redis 后端。要使用 Redis 后端,您必须安装 tornado-redis。
所以龙卷风芹菜不支持 redis 作为经纪人......当我使用 Rabbitmq 作为代理 + Redis 作为后端时,它可以工作。