【python小随笔】celery周期任务（简单原理）

概述1：目录结构 |--celery_task |--celery.py # 执行任务的main函数 |--task_one # 第一个任务 |--task_two # 第2个任务 . . . . |--

1：目录结构

|--celery_task    |--celery.py             # 执行任务的main函数    |--task_one               第一个任务    |--task_two               第2个任务            .                    .            .                    .    |--task_.                # 第n个任务

2：celery.py

from celery import Celery          导入celery模块from celery.schedules import crontab    周期定义工具包 配置任务celery_task = Celery(    "task",broker=redis://127.0.0.1:6379=[Celery_task.task_one",]     任务文件夹名称.任务文件，多个往后面添加) crontab(minute='*/720') # 12小时执行一次# "schedule": 10,# 每10秒钟执行一次 周期时间定义celery_task.conf.beat_schedule = {    each1d_task: {        ": Celery_task.task_keyword.monitored_ranking 要执行的函数名        schedule": crontab(minute='*/720'),1)"> 12小时执行一次         "args": (10,10)    },}        

3：任务文件配置

from Celery_task.celery import celery_task      导入执行主函数文件from keywords.vIEws.celery_monitored_ranking import KeywordRun  这里是直接导入执行的文件的执行函数import traceback   日志错误详细显示模块from logging_files import logging_main   导入日志对象

@celery_task.task        配置文件中的名称要一样def monitored_ranking():    try:        KeywordRun()       执行函数    except Exception as e:        msg = traceback.format_exc()        logging_main.monitored_ranking_error.error(msg)

 

总结

以上是内存溢出为你收集整理的【python小随笔】celery周期任务（简单原理）全部内容，希望文章能够帮你解决【python小随笔】celery周期任务（简单原理）所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。