pip install celery
python
from celery import Celery
app = Celery('myapp', broker='amqp://guest@localhost//', backend='rpc://')
python
@app.task
def add(x, y):
return x + y
celery -A myapp worker --loglevel=info
python
from myapp import add
result = add.apply_async(args=(4, 2))
python
print(result.get())
python
from datetime import timedelta
app.conf.beat_schedule = {
'every-30-seconds': {
'task': 'myapp.add',
'schedule': timedelta(seconds=30),
'args': (4, 2)
},
}
