pip install celery
# celeryconfig.py
# tasks.py
from celery import Celery
app = Celery('tasks', broker='amqp://guest:guest@localhost:5672//')
@app.task
def add(x, y):
return x + y
celery -A tasks worker --loglevel=info
python
# main.py
from tasks import add
result = add.delay(4, 6)
print(result.get())
