可控制调度执行的celery小插件 celery-task-tigger

MIT
Python
跨平台
2016-06-01
boylegu

众所周知,Celery是Python中非常著名的任务队列框架,其中还包含了一个“定时调度任务”的大杀器,其机制大致就是通过Celery内置的celerybeat来开启一个进程,然后把对应worker中的任务定时丢给rabbitmq或者redis来去跑。其实简单的来说,就是当你开启celery的时候,你希望被调度的任务已经开始跑了。

如果有一天我们希望自己来去控制何时开始跑定时任务并且何时去停止,那么这个问题就稍微有点复杂......所以在这里celery-task-tigger这个小插件或许能助你一臂之力。

用起来非常简单,你只需要引入一行代码就能搞定,举个例子:

from celery_tasktigger.decorator import tigger_task

@app.task(bind=True)
@tigger_task(max_times='forever')
def add(self, x, y):
    return x + y

装饰器@tigger_task 提供了2个参数:max_times和countdown

1. max_times

输入类型为Int, 表示最多可执行几次,其中有一个特殊参数‘forever’表示无限执行

2. countdown

输入类型Int,表示每次执行结束的几秒后进行再次执行,默认为1秒

然后你就可以随心所欲的来控制你自己的task,并且100%兼容celery

更多的详情,你可以进入该项目的Github的首页

加载中

评论(0)

暂无评论

Celery-Task-Tigger v0.4发布, 可控制定时调度任务的小插件

celery-task-tigger 0.4正式发布。它是基于Celery的一种可自由触发定时调度任务的小插件,通俗地说,如果有一天我们希望自己来去控制何时开始跑定时任务并且何时去停止,比如当点击某个按钮或...

2017/05/12 13:48

Celery-Task-Tigger v0.3 发布,可控制定时调度任务的小插件

众所周知,Celery是Python中非常著名的任务队列框架,其中还包含了一个“定时调度任务”的大杀器,其机制大致就是通过Celery内置的celerybeat来开启一个进程,然后把对应worker中的任务定时丢...

2016/06/03 00:50

没有更多内容

加载失败,请刷新页面

没有更多内容

暂无问答

Python - Django分布式Celery使用

python, celery

2016/06/01 10:44
220
0
Celery 入门-简单任务开发

# 安装 pip install celery # pip install flower #celery的及时监控组件 # 配置 > 默认celery的配置文件名是celeryconfig.py,本例的内容如下: BROKER_URL ='amqp://guest:guest[@localhost...

2016/09/16 23:32
151
0
在django中使用Celery 和 Celery-Flower

在django中使用Celery 和 Celery-Flower 1、Celery方式的选择 这里Celery的中间人,我采用Redis。也可以用Django自身和mongodb等。Celery的中间人你可以理解为在Celery执行过程中的数据支持。...

2018/09/25 15:12
46
0
Celery 实现分布式任务队列

记录了一些在用 Celery 实现分布式任务队列时遇到的问题。

2015/09/01 13:28
2.4K
4
django使用celery学习记录

celery是一个异步任务队列/基于分布式消息传递的作业队列

2016/05/04 19:53
1K
1
用 Celery 实现邮件推送系统

邮件的发送存在耗时长,成功率不稳定等问题,需要进行异步处理,并且异步处理时还应该根据发送状态考虑重发。

2015/09/02 11:01
1K
1
Django框架17: Celery的使用

Celery介绍 1.什么是Celery Celery是一个python模块,它在官网的定义:Celery is asynchronous task queue/job based on distributed message passing. It is focused on real-time operatio...

2018/09/26 16:28
49
0
项目 3

from __future__ import absolute_import, unicode_literals import os from celery import Celery from django.conf import settings # set the default Django settings module for the 'c...

02/25 00:37
1
0
Django配置celery执行异步任务和定时任务

原生celery,非djcelery模块,所有演示均基于Django2.0 celery是一个基于python开发的简单、灵活且可靠的分布式任务队列框架,支持使用任务队列的方式在分布式的机器/进程/线程上执行任务调度...

2018/07/31 12:54
911
1

没有更多内容

加载失败,请刷新页面

返回顶部
顶部