celery使用（celery使用kafka）

celery使用（celery使用kafka）

##celery_study.pyfrom celery import Celeryapp=Celery('tasks',broker='amqp://guest@192.168.1.79//')@app.taskdef add(x,y): return x+y

linux shell启动：celery -A celery_study worker --loglevel=info

linux shell#cd 到celery_study.py的目录 执行python

>>from  celery_study import add

>>add.delay(3,4)

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。