Celery5.0 定期任务的重启和动态添加和删除的实现

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

推荐学习书目

› 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

This topic created in 1986 days ago, the information mentioned may be changed or developed.

１．通过 Python （ Flask ）启动，但是不知道如何重启（想到的是通过进程名强制关闭后再启动）

subprocess.Popen(['celery', '-A', 'vextia.celery', 'beat', '-s', 'temp/celerybeat-schedule'])

２．如果想通过画面来管理定时任务的话，如何添加和删除任务

参考官方文档，初始化时可以实现添加定时任务

https://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#entries

Celery5.0 好像实现了 django 的类似动态管理功能，不知有什么好建议。 https://stackoverflow.com/questions/10194975/how-to-dynamically-add-remove-periodic-tasks-to-celery-celerybeat/55603127#55603127

9 replies • 2020-12-04 18:33:50 +08:00

a719114136

Nov 19, 2020

为啥要通过 flask 启动？

sunhk25

Nov 19, 2020 via Android

@a719114136
开发阶段图省事跟应用一块启动

nonduality

Nov 19, 2020

用 supervisor 管理 celery 进程，别用 subprocess 或 shell 脚本。动态增删 celery 任务可以参考 celery-beat 的代码，我基于 celery-beat 的 model 和 api 实现过。

sunhk25

Nov 19, 2020

@nonduality
谢谢建议，supervisor 看样子不错，需要 Linux 容器来开发
动态增删看来还是没有太简单方便的方法

fhsan

Nov 20, 2020

嗯，django-celery-beat

Macv1994

Nov 20, 2020 via Android

可以考虑 flask-apscheduler

sunhk25

Nov 20, 2020

@Macv1994 现在看起来 flask-apscheduler 定时任务管理方便些

oP6Vjjm95MR4Ht2O

Dec 2, 2020

定时任务落地到数据库中,删除和添加还不是你想怎么来就怎么来

jwen

Dec 4, 2020

刚好在弄这个，我用的 flask-apschduler，还可以
supervisor 也提供了 api 出来的，所以都可以在一个 web 界面控制 crontab 和自定义的 job