pip install celery python from celery import Celery app = Celery('myapp', broker='amqp://guest:guest@localhost//') app.conf.task_routes = {'myapp.tasks.*': {'queue': 'myqueue'}} app.conf.result_backend = 'db+sqlite:///results.sqlite' app.autodiscover_tasks(['myapp.tasks']) python from celery import Celery app = Celery('myapp', broker='amqp://guest:guest@localhost//') @app.task def add(x, y): return x + y celery -A myapp worker --loglevel=info python from myapp.tasks import add result = add.delay(4, 6) print(result.get()) celery.py python from celery import Celery app = Celery('myapp', broker='amqp://guest:guest@localhost//') app.conf.task_routes = {'myapp.tasks.*': {'queue': 'myqueue'}} app.conf.result_backend = 'db+sqlite:///results.sqlite' app.autodiscover_tasks(['myapp.tasks']) myapp/tasks.py python from celery import Celery app = Celery('myapp', broker='amqp://guest:guest@localhost//') @app.task def add(x, y): return x + y main.py python from myapp.tasks import add result = add.delay(4, 6) print(result.get())