Python异步任务celery，celery定时任务，定时发送邮件、短信、执行清理等等。。

详细的celery可以看这篇博客：

Python异步任务celery的使用，celery分布式队列管理工具 | 定时任务

话不多说上代码，这里是模块化了celery

环境

celery == 3.1.25

redis == 2.10.0

目录结构：

代码

一、__init __.py初始化文件

from celery import Celery

app = Celery('demo')
# 通过celery实例加载配置模块，配置信息在celeryconfig.py文件中
app.config_from_object('celery_task.celeryconfig')

           

二、celeryconfig.py配置文件

from datetime import timedelta
from celery.schedules import crontab

BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
# 时区
CELERY_TIMEZONE = 'Asia/Shanghai'

# 导入指定的任务模块
CELERY_IMPORTS = (
    'celery_task.tasks'
)

# 定时任务
CELERYBEAT_SCHEDULE = {
    # 任务一，每10秒指定一次
    'task_1': {
        # 指定任务
        'task': 'celery_task.tasks.number_add',
        # 每十秒执行一次
        'schedule': timedelta(seconds=10),
        # 参数
        'args': (3, 6)
    },
    # 任务二，定时执行，每天固定时间执行
    'task_2': {
        # 指定任务
        'task': 'celery_task.tasks.number_mult',
        # 每天执行，这里写的18:31
        'schedule': crontab(hour=18,minute=31),
        # 参数
        'args': (3, 6)
    }
}


           

三、tasks.py任务管理，

# 模块化之后
from celery_task import app

@app.task
def number_add(x, y):
    time.sleep(4)
    print('number_add 进来了...')
    return x + y


@app.task
def number_mult(x, y):
    print('定时-乘法')
    return x * y

           

四、tast.py文件，用来执行任务–不是定时任务，是’手动触发’

# 模块化之后
from celery_task import tasks
# 调用方法
if __name__ == '__main__':
    print('start task...')
    result = tasks.number_add.delay(3, 5)
    print('end task...')
    num = result.get()
    print(num)
           

五、celery启动命令

两条命令

celery beat是用来开启定时任务调度的

celery beat -A celery_task -l INFO

           

celery worker -A celery_task -l INFO

           

详细的celery可以看这篇博客：

Python异步任务celery的使用，celery分布式队列管理工具 | 定时任务