zoukankan      html  css  js  c++  java
  • Celery-------周期任务


    在项目目录例子的基础上进行修改一下celery文件

    from celery import Celery
    from celery.schedules import crontab
    
    celery_task = Celery("task",
                         broker="redis://127.0.0.1:6379",
                         backend="redis://127.0.0.1:6379",
                         include=["Celery_task.task_1","Celery_task.task_2"])
    
    #我要要对beat任务生产做一个配置,这个配置的意思就是每10秒执行一次Celery_task.task_1任务参数是(10,10)  PS: 这里我们并没真的用到参数 只是举个例子
    celery_task.conf.beat_schedule={
        "each10s_task":{
            "task":"Celery_task.task_1.func1",
            "schedule":10, # 每10秒钟执行一次
            "args":(10,10)
        },
        "each1m_task": {
            "task": "Celery_task.task_1.func1",
            "schedule": crontab(minute=1), # 每一分钟执行一次
            "args": (10, 10)
        },
        "each24hours_task": {
            "task": "Celery_task.task_1.func1",
            "schedule": crontab(hour=24), # 每24小时执行一次
            "args": (10, 10)
        }
    
    }
    
    #以上配置完成之后,还有一点非常重要
    # 不能直接创建Worker了,因为我们要执行周期任务,所以首先要先有一个任务的生产方
    # celery beat -A Celery_task
    # celery worker -A Celery_task -l INFO -P eventlet

    创建Worker的方式并没有发行变化,但是这里要注意的是,每间隔一定时间后需要生产出来任务给Worker去执行,这里需要一个生产者beat

    celery beat -A Celery_task  #创建生产者 beat 你的 schedule 写在哪里,就要从哪里启动

  • 相关阅读:
    Linux学习-网络管理
    Linux学习-文件权限
    Linux学习-用户管理常用命令
    python操作数据库(MySQL、redis、MD5加密函数)
    Jenkins待过的坑
    Robot framework+Jenkins
    jenkins + maven + SVN自动化集成部署
    接口测试学习笔记二
    接口测试学习笔记一
    【数据结构】为什么要使用一致性哈希算法?
  • 原文地址:https://www.cnblogs.com/Treasuremy/p/10396388.html
Copyright © 2011-2022 走看看