技术标签: 中间件 Python Celery
$ pip install django-celery-beat
#jdango时区配置
# 官方用来修复CELERY_ENABLE_UTC=False and USE_TZ = False 时时间比较错误的问题;
# 详情见:https://github.com/celery/django-celery-beat/pull/216/files
DJANGO_CELERY_BEAT_TZ_AWARE = False
# 使用django_celery_beat插件用来动态配置任务!
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'
$ python manage.py migrate
INSTALLED_APPS = [
...
'django_celery_beat',
...
]
迁移之后生产几个表:
django_celery_beat.models.PeriodicTask # 此模型定义要运行的单个周期性任务。
django_celery_beat.models.IntervalSchedule # 以特定间隔(例如,每5秒)运行的计划。
django_celery_beat.models.CrontabSchedule
# 与像在cron项领域的时间表 分钟小时日的一周 DAY_OF_MONTH month_of_year
django_celery_beat.models.PeriodicTasks # 此模型仅用作索引以跟踪计划何时更改
django_celery_beat_solarschedule # 根据太阳升起降落定制任务
django_celery_beat_clockedschedule # 此模型存放已经关闭的任务
celery -A proj beat -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler #启动beat 调度器使用数据库
celery worker -A taskproj -l info #启动woker
python manage.py createsuperadmin
此时celery就会按照任务定义的时间间隔定时想中间人发送任务。
class CrontabCliJob(CrontabBaseJob):
'''
调用django-celery-beat的model 实现创建更新任务
'''
type_choices = (
('单纯采集', '单纯采集'),
('采集解析', '采集解析')
)
# status_choices = (('running', '进行中'), ('stopped', '停止'), ('err', '错误'))
type = models.CharField(max_length=50, verbose_name='采集种类', choices=type_choices, null=True, blank=True)
cmds = models.TextField(verbose_name='执行的命令', null=True, blank=True)
cmdb_api = models.URLField(verbose_name='CMDB在线资源API地址', default='http://zet.bocsys.cn/cmdb/device')
device_filter = models.TextField(verbose_name='设备筛选条件', null=True, blank=True)
filter_script = models.TextField(verbose_name='设备删选脚本', null=True, blank=True)
auth = models.TextField(verbose_name='认证信息', null=True, blank=True)
parse_textfsm = models.TextField(verbose_name='解析textfsm', null=True, blank=True)
parse_scripts = models.ManyToManyField('parse.Parser')
def save(self, *args, **kwargs):
period_task_obj = PeriodicTask.objects.filter(name=self.job_name).first()
if not period_task_obj:
# 周期任务创建的前提是具备: jobname cmds dev_filter crontab_str
if self.job_name and self.crontab_str:
description = self.description
start_time = datetime.now()
crontab = get_or_update_crontab_schedule_obj(self.crontab_str)
period_task_obj = PeriodicTask(
name=self.job_name,
task=CrontabCliJobTaskName,
crontab=crontab,
start_time=start_time,
description=description,
)
period_task_obj.save()
else:
description = self.description
crontab = get_or_update_crontab_schedule_obj(self.crontab_str)
period_task_obj.name = self.job_name
period_task_obj.task = CrontabCliJobTaskName
period_task_obj.crontab = crontab
period_task_obj.description = description,
period_task_obj.save()
self.periodic_task = period_task_obj
# 没有创建周期任务则根据参数判断是否可以创建周期任务
super(CrontabCliJob, self).save(*args, **kwargs)
class Meta:
verbose_name = '命令行任务详情'
verbose_name_plural = verbose_name
文章浏览阅读1.7k次。可以看到很多联发科的MT芯片摘自:https://net.zol.com.cn/531/5312999.html彻底扒光 通过智能路由器拆解看其本质2015-07-23 00:40:00[中关村在线 原创] 作者:陈赫|责编:白宁收藏文章 分享到 评论(24)关注智能路由器拆解的朋友们注意啦!我们已经将这五款产品彻底扒开,将主板的真容展现在了大家的眼前。网友们可以看见这些智能路由器主板的做工和用料,我们还为网友们展示了主要的电子元器件,供大家品评观赏。..._路由器拆解
文章浏览阅读2.1k次,点赞101次,收藏78次。【学习背景】今天主要是来了解Java线程Thread中的run()、start()两个方法的执行有哪些区别,会给出一个简单的测试代码样例,快速理解两者的区别,再从源码层面去追溯start()底层是如何最终调用Thread#run()方法的,个人觉得这样的学习不论对面试,还是实际编程来说都是比较有帮助的。进入正文~学习目录一、代码测试二、源码分析2.1 run()方法2.2 start()方法三、使用总结一、代码测试执行Thread的run()、start()方法的测试代码如下:public_jdk的源码hotspot跟jdk是分开的
文章浏览阅读4.4k次,点赞90次,收藏85次。俄乌冲突中,各方势力通过数据擦除恶意软件破坏关键信息基础设施计算机的数据,达到深度致瘫的效果,同时窃取重要敏感信息。_俄乌网络战观察(一)
文章浏览阅读1.7w次,点赞23次,收藏139次。Maven 私服是一种特殊的Maven远程仓库,它是架设在局域网内的仓库服务,用来代理位于外部的远程仓库(中央仓库、其他远程公共仓库)。当然也并不是说私服只能建立在局域网,也有很多公司会直接把私服部署到公网,具体还是得看公司业务的性质是否是保密的等等,因为局域网的话只能在公司用,部署到公网的话员工在家里也可以办公使用。_nexus maven
文章浏览阅读934次。我先用所有的样本数据对模型做几轮初步训练,让深度神经模型基本拟合(数万条记录的训练集,识别率到99%左右),具备初步的识别能力,这时的模型就是“直男”。相较于训练很多轮、拟合程度很高的“油腻男”,它的拟合程度较低,还是“直男愣头青”。..............._java ocr ai识别训练
文章浏览阅读688次。一、问题现象: 在数据库表中日期字段中存的日期光有年月日,没有时分秒。二、产生原因:三 解决办法 检查表的相应映射xml文件。 <property name="operateDate" type="Date">如果同上面所写,那问题出在 type类型上了正确写法 :<property name="operateDate" type="java.util..._hibernate解析時間只有年月日沒有時分秒
文章浏览阅读1k次,点赞2次,收藏2次。文章目录问题描述:解决方案:问题描述:提示:idea springbbot运行无法编译成功,找不到jar包报错E:\ideaProject\demokkkk\src\main\java\com\example\demo\config\WebSocketConfig.javaError:(3, 46) java: 程序包org.springframework.context.annotation不存在Error:(4, 46) java: 程序包org.springframework.conte_error:(3, 46) java: 程序包org.springframework.context.annotation不存在
文章浏览阅读6.4k次,点赞6次,收藏36次。1、redux中间件中间件提供第三方插件的模式,自定义拦截 action -> reducer 的过程。变为 action -> middlewares -> reducer 。这种机制可以让我们改变数据流,实现如异步 action ,action 过滤,日志输出,异常报告等功能。常见的中间件:redux-logger:提供日志输出redux-thunk:处理异步操作..._recate面试
文章浏览阅读405次。由于要在开发板中加载libjpeg,不能使用gcc编译的库文件给以使用,需要自己配置使用另外的编译器编译该库文件。/usr/bin/ld:.libs/jaricom.o:RelocationsingenericELF(EM:40)/usr/bin/ld:.libs/jaricom.o:RelocationsingenericELF(EM:40)...._jpeg_utils.lo: relocations in generic elf (em: 8) error adding symbols: file
文章浏览阅读578次,点赞10次,收藏17次。【办公类-22-06】周计划系列(1)“信息窗” (2024年调整版本)
文章浏览阅读309次。SEO全称为Search Engine Optimization,中文解释为搜索引擎优化。一般指通过对网站内部调整优化及站外优化,使网站满足搜索引擎收录排名需求,在搜索引擎中提高关键词排名,从而把精准..._百度seo resetful
文章浏览阅读438次。回归预测 | Matlab实现HPO-ELM猎食者算法优化极限学习机的数据回归预测_猎食者优化算法