tornado+celery的简单使用详解
celery是实现一个简单，灵活可靠的分布式任务队列系统的好选择
tornado则不用过多介绍
在开发机上安装rabbitmq这里就不介绍了
首先是task文件的编写
task.py
#coding=utf-8
fromceleryimportCelery
fromcelery.binimportworkerascelery_worker
importceleryconfig
broker='amqp://'
backend='amqp'
app=Celery('celery_test',backend=backend,broker=broker)
app.config_from_object(celeryconfig)
@app.task
defmytask0(task_name):
print"task0:%s"%task_name
returntask_name
@app.task
defmytask1(task_name):
print"task1:%s"%task_name
returntask_name
defworker_start():
worker=celery_worker.worker(app=app)
worker.run(broker=broker,concurrency=4,
traceback=False,loglevel='INFO')
if__name__=="__main__":
worker_start()
celeryconfig.py文件中包含对celery的配置
#coding=utf-8
fromkombuimportQueue
CELERY_DEFAULT_QUEUE='mytask0'
CELERY_QUEUES=(
Queue('mytask0',routing_key='task.mytask0'),
Queue('mytask1',routing_key='task.mytask1'),
)
CELERY_DEFAULT_EXCHANGE_TYPE='direct'
CELERY_DEFAULT_ROUTING_KEY='task.mytask0'
CELERY_TIMEZONE='Asia/Shanghai'
CELERY_ROUTES={
'task.mytask0':{
'queue':'mytask0',
'routing_key':'task.mytask0',
},
'task.mytask1':{
'queue':'mytask1',
'routing_key':'task.mytask1',
},
}
执行pythontask.py将会启动worker
tornado调用celery将阻塞任务变为非阻塞
这会使用到tcelery模块，即tornado下的一个非阻塞的broker实现
app.py
#coding=utf-8
fromtornadoimportweb
importtask
classTestHandler(tornado.web.RequestHandler):
@web.asynchronous
defget(self):
task.mytask0.apply_async(
args=['task0'],
queue='mytask0',
routing_key='task.mytask0',
callback=self.on_success)
defon_success(self,result):
self.finish({'task':result.result})
start.py
用于实现tornado服务的启动
#coding=utf-8
importtornado
fromtornado.optionsimportdefine,options,parse_command_line
fromtornado.logimportenable_pretty_logging
importtcelery
fromappimportTestHandler
importtornado.httpserver
define("port",default=8000,help="runonthegivenport",type=int)
define("debug",default=False,help="runindebugmode")
urls=[(r"/api/task/test",TestHandler)]
defserver_start():
app=tornado.web.Application(urls,debug=options.debug)
enable_pretty_logging()
parse_command_line()
server=tornado.httpserver.HTTPServer(app)
server.bind(options.port)
server.start(2)
tcelery.setup_nonblocking_producer(limit=2)
tornado.ioloop.IOLoop.current().start()
if__name__=="__main__":
server_start()
执行pythonstart.py即可启动服务
以上这篇tornado+celery的简单使用详解就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。