Steward

分享是一種喜悅、更是一種幸福

程式語言 - Python - v3.x - Celery

---

tasks.py

from celery import Celery

app = Celery(
    'hello',
    broker='redis://localhost:6379/0',
    backend='redis://localhost:6379/0'
)

@app.task
def hello(name):
    return f"Hello, {name}!"

hello.py

from tasks import hello

r = hello.delay("World")
print(r.get(timeout=10))

執行

$ sudo apt install redis-server celery
$ pip install celery redis

$ redis-server
$ celery -A tasks worker --loglevel=info

$ python3 ./hello.py 
    Hello, World!