celery tasks.py

#!/usr/bin/python
# -*- coding: utf-8 -*-
# utf-8 中文编码


from celery import Celery


app = Celery('tasks', backend='redis://localhost', broker='redis://localhost')

app.conf.CELERY_TASK_SERIALIZER = 'json'
app.conf.CELERY_IGNORE_RESULT = False
app.conf.CELERY_ACCEPT_CONTENT = ["json"]
app.conf.CELERY_RESULT_SERIALIZER = 'json'
app.conf.CELERY_TRACK_STARTED = True


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