shell pip install celery python from celery import Celery celery_app = Celery("myapp", broker="amqp://guest:guest@localhost:5672//") python from myapp.celery import celery_app @celery_app.task def process_event(event): return result python from myapp.tasks import process_event result = process_event.delay(event) python from myapp.tasks import process_event @celery_app.task(bind=True, name="myapp.event_handler") def event_handler(self, event): result = process_event(event) shell celery -A myapp worker --loglevel=info python result = process_event.delay(event) python def callback_func(result): pass result = process_event.delay(event) result.then(callback_func)