#!/usr/bin/evn python

# coding=utf-8

"""

Author = zyx

@Create_Time: 2018/1/30 15:58

@version: v1.0.0

@File: main.py

@文件功能描述:

"""

from bottle import route, run

@route('/')

def index():

    return '访问了首页！'

run(host='127.0.0.1', port=8080, debug=True, reloader=True)

# coding:utf-8

from datetime import timedelta

from kombu import Exchange, Queue

# 配置消息中间件Broker

BROKER_URL = 'redis://127.0.0.1:6379/0'

# 配置结果存贮Backend

CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/1'

# 指定时区，默认是 UTC

CELERY_TIMEZONE = 'Asia/Shanghai'

CELERY_ENABLE_UTC = True

#限制所有的任务的刷新频率

CELERY_ANNOTATIONS = {'*':{'rate_limit':'10/s'}}

# # 不需要返回任务状态，即设置以下参数为True

# 如果不需要某个任务的结果，应该确保Celery不去获取这些结果。这是通过装饰器@task(ignore_result=True)来做的。如果所有的任务结果都忽略了，就不必定义结果后台。这可以让性能大幅提高。

CELERY_IGNORE_RESULT = True

# 任务序列化和反序列化使用msgpack方案

# CELERY_TASK_SERIALIZER = 'json'

# 读取任务结果一般性能要求不高，所以使用了可读性更好的JSON

# CELERY_RESULT_SERIALIZER = 'json'

# 指定任务模块

CELERY_IMPORTS = (

    'celery_test.tasks',

)

# celery worker的并发数 也是命令行-c指定的数目,事实上实践发现并不是worker也多越好,保证任务不堆积,加上一定新增任务的预留就可以

CELERYD_CONCURRENCY = 10

CELERYD_FORCE_EXECV = True  # 非常重要,有些情况下可以防止死锁

# celery worker 每次去redis取任务的数量，我这里预取了4个慢慢执行,因为任务有长有短没有预取太多

CELERYD_PREFETCH_MULTIPLIER = 4

#每个worker执行了多少次任务后就会死掉，建议数量大一些

CELERYD_MAX_TASKS_PER_CHILD = 200

# CELERY_ACCEPT_CONTENT = ['json']  # 指定接受的内容类型

#celery任务执行结果的超时时间

CELERY_TASK_RESULT_EXPIRES = 1200

#单个任务的运行时间限制，否则会被杀死

CELERYD_TASK_TIME_LIMIT = 60

# # 默认的队列，如果一个消息不符合其他的队列就会放在默认队列里面

# CELERY_DEFAULT_QUEUE = "default"

#

# CELERY_QUEUES = (

#     Queue('default', Exchange('default'), routing_key='default'),# 这是上面指定的默认队列

#     Queue('for_add', Exchange('for_task_add'), routing_key='for_task_add'), # 这是一个for_add队列 凡是for_task_add开头的routing key都会被放到这个队列

#     Queue('for_send_email', Exchange('for_task_email'), routing_key='for_task_email'),

# # 这是一个or_send_email'队列 凡是for_task_email开头的routing key都会被放到这个队列

# )

#

# CELERY_ROUTES = {

#     'celery_test.tasks.add': {'queue': 'for_add', 'routing_key': 'for_task_add'},

#     'celery_test.tasks.easeye_send_mails': {'queue': 'for_send_email', 'routing_key': 'for_task_email'},

# }

#

#定时任务

CELERYBEAT_SCHEDULE = {

    'easeye_send_mail': {

        'task': 'celery_test.tasks.easeye_send_mails',

        'schedule': timedelta(seconds=30),

    },

    'add': {

        'task': 'celery_test.tasks.add',

        'schedule': timedelta(seconds=10),

        'args': (16, 16)

    }

}

from  celery import Celery

app=Celery('celery_test',include=['celery_test.tasks'])

app.config_from_object('celery_test.setting')

if __name__=='__main__':

    app.start()

# coding:utf-8

from celery_test.server import app

@app.task(bind=True)

def add(self,x, y):         #自己放项目里 一定不要忘了self

    return x + y

@app.task(bind=True)

def send_mail(self,x, y):

    return x - y

from bottle import route, run, redirect

from celery_test import tasks

# @route('/add')

# def index():

#     tasks.add.daley(888, 45)

#     return '访问了add！'

@route('/send_mail')

def index():

    task = tasks.send_mail.delay(888, 45)

    print('访问了send_mail！')

    return redirect('/tasks_status/' + task.id)  # 重定向到首页(可以 )

@route('/tasks_status/<task_id>')

def index(task_id):

    # 获取异步任务结果

    task = tasks.send_mail.AsyncResult(task_id)

    # 等待处理

    if task.state == 'PENDING':

        response = {'state': task.state, 'current': 0, 'total': 1}

        print('PENDING：', response)

    elif task.state != 'FAILURE':

        response = {'state': task.state, 'current': task.info.get('current', 0), 'total': task.info.get('total', 1)}

        # 处理完成

        if 'result' in task.info:

            response['result'] = task.info['result']

        print('处理完成：', response)

    else:

        # 后台任务出错

        response = {'state': task.state, 'current': 1, 'total': 1}

        print('后台任务出错：', response)

run(host='127.0.0.1', port=8080, debug=True, reloader=True)