# 自定义异步

import djcelery

djcelery.setup_loader()

# BROKER_URL = 'django://' # 使用django做broker,消息代理、队列

BROKER_URL = 'redis://10.255.0.250:6379/4'  # 使用redid做broker，消息代理、队列

CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'  # 这是使用了django-celery默认的数据库调度模型,任务执行周期都被存在你指定的orm数据库中

# BROKER_POOL_LIMIT = 0

CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'  # 需要跟踪任务的状态时保存结果和状态，结果存储

# CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/2'

CELERY_TIMEZONE = 'Asia/Shanghai'  # 默认上海时区

CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']

CELERY_TASK_SERIALIZER = 'json'

CELERY_RESULT_SERIALIZER = 'json'

# 调度任务

from datetime import timedelta

from celery.schedules import crontab

CELERYBEAT_SCHEDULE = {

    # 定时任务

    'daybreake': {

        'task': 'emall_app.tasks.add',

        'schedule': crontab(minute=u'', hour=u''),

        'args': (2, 3)

    },

    # 定期任务

    'add-every-3-secondes': {

        'task': 'emall_app.tasks.add',

        'schedule': timedelta(seconds=10),

        'args': (5, 5)

    },

}

@task

def add(x, y):

    return x + y

from emall_app.tasks import add

from prod_core import constants

from prod_core.decorators import json_response

@json_response

def task_demo(request):

    result = add.delay(2, 2)

    log.exception('=========== result')

    log.exception(result)

    if result.ready():

        print "Task has run"

        if result.successful():

            print "Result was: %s" % result.result

        else:

            if isinstance(result.result, Exception):

                print "Task failed due to raising an exception"

                raise result.result

            else:

                print "Task failed without raising exception"

    else:

        print "Task has not yet run"

    return {'code': constants.RESULT_SUCCESS}