Celery Demo

Celery

rabbitmq

yum install erlang

yum install rabbitmq-server -y
systemctl start rabbitmq-server
systemctl enable rabbitmq-server

redis

yum repolist
yum install redis php-pecl-redis
systemctl start redis
systemctl enable redis
pip install redis

client.py

from tasks import add
add.delay(5, 5)
with open('output.log', 'a') as f:
    f.write('===== current ====' + "\n")

tasks.py

from celery import Celery
app = Celery('tasks', broker='redis://guest@localhost//')
@app.task
def add(x, y):
    with open('output.log', 'a') as f:
        f.write('===== delay ====' + "\n")
    return x + y

Command

server:

celery -A tasks worker --loglevel=info

client:

python client.py