Celery + redis quick start.

软件:

redis server redis-server.exe

安装redis for python using pip

安装celery (redis)  pip install -U "celery[redis]"

 

代码:

==tasks.py

from celery import Celery

#app = Celery('tasks', broker='pyamqp://guest@localhost//')
#app = Celery('tasks', broker='redis://localhost:6379/0')
app = Celery('tasks', backend='redis://localhost:6379/0',broker='redis://localhost:6379/0')

@app.task
def add(x, y):
    return x + y

 

==testCelery.py

from tasks import add
from celery import Celery

#app = Celery('tasks', backend='rpc://', broker='redis://localhost')
app = Celery('tasks', backend='redis://localhost:6379/0',broker='redis://localhost:6379/0')

result = add.delay(4, 4)
print(result.get())

步骤:

打开一个命令行,执行redis-server

打开一个命令行,执行

set FORKED_BY_MULTIPROCESSING=1

celery.exe -A tasks worker --loglevel=info

打开一个命令行,执行..\python.exe testCelery.py

 

结果:

 

Powered by Jekyll and Theme by solid

本站总访问量