个人中心
文章发布
退出
作者热门文章
- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时，我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
34
4
我有一个不包含 Django 的项目，所以我不能使用 djcelery。
但我找到了 modification的 django-celery DatabaseSchedule使用 sqlalchemy。
它像 djceley 的 DatabaseScheule 一样工作正常。但是唯一的问题是它似乎没有发送运行时添加的任务，然后我重新启动celery-beat，之前添加的任务将成功发送。
那么，是否可以在不重启 celery-beat 的情况下动态添加/删除任务？
感谢您的任何建议。抱歉我的英语不好。
对不起，是我的错。在运行时添加的任务不会立即被拾取，您可以将 DatabaseScheduler.sync_every 值更改为更快的值。所以它在等待几分钟后工作。
感谢tuomur的帮助。
最佳答案
解决方案一:
我也有同样的问题，问题是，Celery 周期性调度程序会寻找 [djcelery_periodictasks] ，它会有 [last_update] 值。如果 [last_update] 没有变化，那么 celery 将不会检查 [djcelery_periodictask] 表。
我们要做的是，每当您添加/删除任务时，更新 [djcelery_periodictasks] 中的 [last_update] 时间。
在我的 senario 中，我有 python 中的周期性 scheduelr。但是我的 Web UI 是用 C# 编写的。我的 Web 应用程序将添加/删除 [djcelery_periodictask] 中的条目并更新 [djcelery_periodictasks] 中的 [last_update] 时间。
通过这种方式，我已经解决了这个问题。
当我们使用标准的 flower UI 时，如果我们添加/删除任务，它将更新 [djcelery_periodictasks] 中的[last_update] 时间>。如果您开发了自己的自定义 UI/应用程序，则必须在 [djcelery_periodictasks] 中包含更新 [last_update] 时间的功能，以动态添加/删除任务。
解决方案2:
关于python - celery celerybeat 可以在运行时动态添加/删除任务吗？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37153373/
34
4
0
我尝试了我能找到的一切，包括: 计算器 How to dynamically add / remove periodic tasks to Celery (celerybeat) Can celery
我想使用django-celery的管理界面为celery创建一个定期任务。我设置了一个任务，当手动或通过脚本调用时，该任务运行得很好。它只是无法通过 celerybeat 工作。根据调试日志，任务在
当我通过 manage.py celerybeat 启动 celerybeat 时，我看到了这个: [2011-07-12 13:37:46,892: WARNING/MainProcess] __
我刚开始使用 celery ，尝试运行一个周期性任务。 已配置 *rabbitmq** 添加了 celeryconfig.py。 并在tasks.py中加入如下代码: from celery.deco
我有 celery 任务: @app.task(ignore_result=True) def update_task(): .... 我在设置中将此任务添加到 celerybeat: CEL
我有一个包含多个 celerybeat 任务的 Django 项目，当我有多个带有单独队列的 celerybeat 任务时，我遇到了一个问题，所以我是否有可能一次运行所有这些任务，运行的最佳实践是什么
我无法通过 celerybeat 计划将参数传递给我的函数。搜索后，看起来我应该能够使用 args 命令传递它们，但我收到了如下错误。谁能指出我正确的方向？ CELERYBEAT_SCHEDULE =
我正在使用 Bottle 构建一些项目，我需要它定期运行某些预定的操作。 我决定使用 rabbitmq + celery，因为这似乎是以编程方式管理计划工作的最强大和最完整的解决方案。 我安装了 ra
我有一个任务calculate_common_locations，它通过CELERYBEAT_SCHEDULE 运行一次。该任务只是调用数据库中的一个函数: @app.task def calcula
我正在使用 celery 构建应用程序，最近我们需要按计划运行某些任务。 我认为 celerybeat 非常适合这个，但我有几个问题: 是否可以运行多个 celerybeat 实例，这样任务就不会重复
我们正在使用 django-celery==3.1.10 celery==3.1.20 python 2.7.13 我们编写了一个 CustomDataBaseScheduler 来调度任务，它可以完
您如何诊断为什么 manage.py celerybeat 不执行任何任务？ 我正在通过 supervisord 使用以下命令运行 celerybeat: /usr/local/myapp/src/m
我发现 celerybeat 在其调度中使用 UTC 时间(并以英国时间输出日志？!)即使我相信我的 django settings.py 中有所需的设置: TIME_ZONE = 'UTC' USE
我有一个使用 celeryd 和 celerybeat 的 django 应用程序。两者都设置为作为守护程序运行。 celerybeat 任务不会被执行，因为 celerybeat 没有正确启动。根据
我正在寻找推荐的解决方案来解决 celerybeat 成为 celery/rabbitmq 部署的单点故障的问题。到目前为止，通过搜索网络，我没有找到任何有意义的东西。 就我而言，定时调度程序每天启动
我正在用 python 编写基于 celerybeat-mongo 的 celerybeat 自定义调度程序类与 mongodb 一起工作的项目。 实际上，我正在尝试使用 couchbase 而不是
我有一个任务，我使用 celerybeat 每分钟执行一次。它工作正常。但有时，任务的运行时间比一分钟多几秒钟，因为任务的两个实例都在运行。这会导致一些竞争条件把事情搞砸。 我可以(而且可能应该)修复
我有以下设置: celery-with-redis - 3.0 - active celery - 3.0.12 - active django-celer
成熟到什么程度 Chronos ?它是像 celery-beat 这样的调度程序的可行替代方案吗？ 现在我们的调度实现了一个周期性的“心跳”任务，它检查“未完成”的事件并在它们过期时触发它们。我们正在
celeryd不需要pidfile，但celerybeat好像。有什么办法可以禁用它吗？我正在使用 Upstart 来管理进程，因此使用 pidfile 是多余的。 最佳答案 以下似乎对一些人有用，所
我是一名优秀的程序员,十分优秀！