推荐学习书目 Learn Python the Hard Way Python Sites PyPI - Python Package Index http://diveintopython.org/toc/index.html Pocoo 值得关注的项目 PyPy Celery Jinja2 Read the Docs gevent pyenv virtualenv Stackless Python Beautiful Soup 结巴中文分词 Green Unicorn Sentry Shovel Pyflakes pytest Python 编程 pep8 Checker Styles PEP 8 Google Python Style Guide Code Style from The Hitchhiker's Guide
这是一个创建于 3923 天前的主题，其中的信息可能已经有所发展或是发生改变。
作为测试，弄了一个git pull 定时任务。预设时间是300秒一次。可是从结果来看，时间间隔有5分钟、10分钟、15分钟等等。
broker用的是redis，不知道是不是这个原因造成的？
目前数据很少啊~ 就两三个定时任务。
broker用的是redis，不知道是不是这个原因造成的？
目前数据很少啊~ 就两三个定时任务。
第 1 条附言 2015-03-24 12:20:06 +08:00
定义5分钟一次celery.py
https://gitcafe.com/rangerwolf/CeleryDemoProjects/blob/master/proj_mgr/celery.py
定义具体任务的tasks.py
https://gitcafe.com/rangerwolf/CeleryDemoProjects/blob/master/proj_mgr/tasks.py
其中最后一个 git_pull 是需要每5分钟执行一次的函数
https://gitcafe.com/rangerwolf/CeleryDemoProjects/blob/master/proj_mgr/celery.py
定义具体任务的tasks.py
https://gitcafe.com/rangerwolf/CeleryDemoProjects/blob/master/proj_mgr/tasks.py
其中最后一个 git_pull 是需要每5分钟执行一次的函数
第 2 条附言 2015-03-25 21:57:38 +08:00
应该是找到原因了
我总共有两个不同的worker，但是他们共享一个broker。估计就是这样造成了冲突。
我总共有两个不同的worker，但是他们共享一个broker。估计就是这样造成了冲突。
 | 1 yueyoum 2015-03-24 10:20:00 +08:00 我当时也学过一段时间 celery ，但是没学会。 果断放弃 可用来替代celery的东西很多。 |
 | 3 no13bus 2015-03-24 10:28:46 +08:00 这个和redis没关系。 |
 | 4 hahastudio 2015-03-24 10:42:59 +08:00 我猜可能的原因是有的时候 5 min 并没有做完？ |
 | 6 RangerWolf OP @hahastudio 你猜的不对:D task的receive time 就不对了~ 每次执行完成的时间不到1秒钟 @no13bus 官方说redis会丢数据。 我以为数据量小的是没关系~ 我再试试看rabitt mq @yueyoum 你用什么代替的？同问 |
 | 7 0bit 2015-03-24 11:23:06 +08:00 我觉着 @hahastudio 猜的可能是对的，Celery的定时只能是保证在那个时间点之后可用，但是你的worker当时可能没忙完别的，你可以监控一下worker的执行，或者多开几个worker试试 |
 | 8 no13bus 2015-03-24 11:35:33 +08:00 celery -A myproject worker -P gevent -c 1000 -l info 这个命令试试。 我知道的定时任务有这些: https://github.com/vinta/awesome-python#job-scheduler 但是我觉得都没有celery功能强大。你的任务应该是很基本的，贴一下你的celery的setting和命令。干说说不出啥来。 |
| 9 RangerWolf OP @no13bus 多谢！ 我把代码放到gitcafe上面去了 定义5分钟一次celery.py https://gitcafe.com/rangerwolf/CeleryDemoProjects/blob/master/proj_mgr/celery.py 定义具体任务的tasks.py https://gitcafe.com/rangerwolf/CeleryDemoProjects/blob/master/proj_mgr/tasks.py 其中最后一个 git_pull 是需要每5分钟执行一次的函数 |
 | 10 lxyu 2015-03-24 13:00:19 +08:00  1 celery 是队列，就不是用来当 cron 用的。celery beat 只是把任务放到了池子里，但是什么时候执行？什么时候执行完？都要看 worker。如果要 debug，可以看 worker 的日志，看当时任务的执行情况和 worker 的情况，也可以在 gitpull 的前后打下日志。 “队列”本身就意味着不定时，如果要做定时任务还是用 cron 吧。 |
| 11 RangerWolf OP @lxyu 好吧 原来是这样~ 多谢指导！ |
Select Language