平台项目~celery 异步之定时任务功能

一简介: 今天来聊聊celery的定时任务功能

二标准流程:

1 配置config.py

from celery.schedules import crontab

CELERYBEAT_SCHEDULE = {
‘ celery_test.tasks.test_run‘: {
‘task‘: ‘celery_test.tasks.test_run‘,
‘schedule‘: crontab(minute=‘*/2‘)
}
}

2 启动woker进程

3 启动crontab 进程

celery -A celery_demo.celery beat -l info -f log

4 查看日志信息

[2019-09-12 10:38:00,011: INFO/MainProcess] Scheduler: Sending due task celery_test.tasks.test_run (celery_test.tasks.test_run)
[2019-09-12 10:38:00,036: DEBUG/MainProcess] celery_test.tasks.test_run sent. id->d16b6bd8-15c6-4d65-b46d-a215602776c0

5 crontab设置

参数 minute hour day_of_week

例子 ‘schedule‘: crontab(minute=0, hour=8, day_of_week=[1, 2, 3, 4, 5]) 每周1-5 早上8点执行

原文地址：https://www.cnblogs.com/danhuangpai/p/11511078.html

时间： 2024-11-08 04:21:53

平台项目~celery 异步之定时任务功能的相关文章

平台项目 ~ celery 异步之异步处理功能

一简介:今天来聊聊celery两大功能之一的异步处理二标准流程: 1 建立 config 文件 class Config: ENABLE_UTC = False CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/5' BROKER_URL = 'redis://127.0.0.1:6379/6' 注意 1 所有参数都必须大写,并且

Celery+python+redis异步执行定时任务

我之前的一篇文章中写了[Celery+django+redis异步执行任务] 博文:http://blog.csdn.net/apple9005/article/details/54236212 你会发现,这些代码并不依赖django框架,随便写到一个py文件中,就可以轻松的执行成功,这是因为这些代码并没有用到django-celery,django-redis等依附于django框架的东西. 今天,参照官方文档示例,测试一下celery的异步执行定时任务如何.我先是在django框架内执行了一

Celery - 一个懂得异步任务 , 定时任务 , 周期任务的芹菜

1.什么是Celery?Celery 是芹菜Celery 是基于Python实现的模块, 用于执行异步定时周期任务的其结构的组成是由 1.用户任务 app 2.管道 broker 用于存储任务官方推荐 redis rabbitMQ / backend 用于存储任务执行结果的 3.员工 worker 2.Celery的简单实例 1 from celery import Celery 2 import time 3 4 #创建一个Celery实例,这就是我们用户的应用app 5

Django使用Celery异步任务队列

1 Celery简介 Celery是异步任务队列,可以独立于主进程运行,在主进程退出后,也不影响队列中的任务执行. 任务执行异常退出,重新启动后,会继续执行队列中的其他任务,同时可以缓存停止期间接收的工作任务,这个功能依赖于消息队列(MQ.Redis). 1.1 Celery原理 Celery的架构由三部分组成,消息中间件(message broker),任务执行单元(worker)和任务执行结果存储(task result store)组成. 消息中间件:Celery本身不提供消息服务,但

电商平台项目

某电商平台项目开发要点记录本文是博主在开发某电商平台项目的一些杂项记录,方便自己和团队同事查阅,偏向于具体技术或应用的细节和个人理解,但也未必非常具体.文中未提的更多内容可能会另起篇章. 导航属性--EF实体关系fluent配置 AutoMapper Autofac Repository模式 Model & DTO 开源&商用.NET电商平台--NopCommerce(3.9版) & Himall(2.4版) 服务器搭建-VMware vSphere Hypervisor(esx

django使用celery异步发送短信

1. 安装celery模块 pip install -U celery==4.3.0 2. 创建celery相关目录 xiaolan/ # 项目主目录 ├── mycelery/ ├── config.py # 配置文件 ├── __init__.py ├── main.py # 主程序 └── sms/ # 一个目录可以放置多个任务,该目录下存放当前任务执行时需要的模块或依赖 └── tasks.py # 任务的文件,名称必须是这个 3. 创建celery配置文件config.py # 注意:

网络远程教育实施方案交流之（二）——网络教育平台项目的建设

网络教育平台项目的建设的方案能够自建也能够採购.但项目是否成功,并终于能够落地发展,还须要业主方认真的调研和分析,最有效的方法就是利用项目管理的方法,从前期的需求分析.调研.可行性分析,立项,建设期成本.质量.进度三大管理,后期測试bugfree,维护.客服服务等. 管理内容看起来复杂,事实上理顺了非常easy,大道至简.下面先从功能模块入手,然后再介绍实践和经验,其目的是让没有经验的读者少走弯路,具有相关经验的管理者分享交流,共同推动此项事业的发展. 曾有人问我项目是不是资金投入越多越好?事实

度量平台项目中菜单的含义及运用

1.菜单的含义项目管理里面的菜单,主要是为这个项目的窗体.表单工作流等定义的功能菜单.在项目内建立的菜单,具有很好的移植性,可以随整个项目一起导到另一个开发平台,也可以单独在这里导出菜单. 2.菜单运用:2.1菜单设置在平台中定义一个菜单有四种模式:程序集.智能窗体.表单流程.网页. 2.2程序集菜单配置程序集:通俗一点讲,就是可以配置一个菜单出来调用我们外部的程序,包括.exe程序,或者DLL(动态库)文件,这个目的就是为了满足我们平台开发不出来的功能时借助外部工具开发后在放到我们平台中

Cocos2d-x3.2 TextureCache类异步加载功能讲解

本文TextureCache类异步加载功能的代码抽出,总共代码就200多行,感兴趣可以看看. 研究这个主要是因为项目中需要异步插入数据,但之前的方法在Android上总是崩溃所以想到TextureCache有异步加载的功能就将其抽出了. 原文地址:http://blog.csdn.net/qqmcy/article/details/39890837 首先,创建AsyncTaskTime类,主要模拟一个费时的方法 AsyncTaskTime.h #include "cocos2d.h"