celery python

proj/__init__.py
    /celery.py
    /tasks.py

proj/celery.py

from celery import Celery

backend = 'redis://127.0.0.1:6379/1'
broker = 'redis://127.0.0.1:6379/2'

app = Celery('proj',
             broker=broker,
             backend=backend,
             include=['proj.task_poi',
                      'proj.task_hn'])

# Optional configuration, see the application user guide.
app.conf.update(
    result_expires=3600,
)

if __name__ == '__main__':
    app.start()

proj/tasks.py

from .celery import app


@app.task
def add(x, y):
    return x + y


@app.task
def mul(x, y):
    return x * y


@app.task
def xsum(numbers):
    return sum(numbers)

$ celery -A proj worker -l info