celerybeat 相关问题

Celery定期任务调度程序

气流是否使用芹菜拍子

气流是否用芹菜拍打?我知道这可能是个简单的问题,但我找不到解决方案。以及如何将芹菜任务添加到气流中。

回答 1 投票 0

Windows上的celery beat + django:[WinError 10061]无法建立连接,因为目标计算机主动拒绝了它

我已经在该站点上尝试了其他解决方案,但是它们没有起作用,而且,许多问题都是旧问题,它们引用了现在已经过时的django-celery-beat软件包。我在Django 3和Celery 4上,它们应该...

回答 1 投票 1

请问使用app.control.purge()时正在运行的任务会发生什么?

[目前,我有一个用django运行的芹菜批次,如下所示:Celery.py:从__future__导入absolute_import,unicode_literals import os从芹菜导入celery从芹菜导入Celery。...]]

回答 2 投票 0

Celery仅在循环中重试失败请求,然后继续其他操作

我对整个celery还是有点陌生 ,并且在for循环上遇到重试情况的问题:我有以下任务:@ app.task(bind = True,autoretry_for =(CustomException,),retry_kwargs = {' max_retries':...

回答 1 投票 0

在芹菜工作者退出之前在KeyboardInterrupt上执行一些操作

遇到键盘中断(例如SIGINT)时,有没有一种方法可以在退出芹菜工人之前执行一些操作?我曾尝试在以下任务中使用信号模块:signal.signal(...

回答 1 投票 0

Celery Beat调度程序不会在Django中执行我的任务

我在Django中设置celery模块时遇到了一些麻烦。我不仅对设置要求感到非常困惑,而且我也很难理解自己的错误。我想在...

回答 1 投票 0

即使队列/并发被占用,Celery也应在呼叫时执行任务

我在Django中有一个celery应用,在其中我以特定的间隔定义了所有定期执行的明智任务。我已经用5个并发celery启动了celery worker -A appname worker --loglevel = info -B -c 5 ...

回答 1 投票 0

django celerybeat不调用task.py函数

基于本教程:https://www.merixstudio.com/blog/django-celery-beat/ celery.py来自__future__的文件代码__导入absolute_import,unicode_literals从celery导入os,从...导入芹菜...

回答 1 投票 0

芹菜节拍每分钟运行一次,而不是每15分钟一次

我正在将芹菜设置为具有时间表CELERYBEAT_SCHEDULE = {'update_some_info':{'task':'myapp.somepath.update_some_info','schedule':crontab(minute ='* / 15'),},} ...

回答 1 投票 1

跟踪多个外键字段之和的最佳方法[Django]

[如果您能想出更好的方式来表达我的问题,请进行更改。这就是我面临的情况。我有2种模式:代理,交易。这是它们看起来的简化版本...

回答 1 投票 1

为什么芹菜节拍不安排定期任务?

我遵循了celery文档[https://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html]创建了一个应用程序和以下定期任务:$ tree demo / demo /├─ ─config.py├──__init__.py└──...

回答 1 投票 0


在运行时更新芹菜节拍时间表

据我所知,celery beat Scheduler的本机实现未提供在运行时添加和同步计划任务的方法。有django-celery-beat,但我不想添加...

回答 1 投票 0

Celery注册任务,但Beat无法从已安装的应用程序调度任务

我在让Celery / Celery Beat安排我的celery.py文件中的任务以外的其他任务时遇到了问题。我可以看到任务已在“芹菜检查已注册”中注册,但任务未在...

回答 1 投票 0

将任务发送给特定的芹菜工作者

我正在构建一个Web应用程序(使用Python / Django),该应用程序托管在连接到负载均衡器的两台计算机上。我有一台中央存储服务器,有一台中央Redis服务器,单芹菜...

回答 2 投票 0

是否有动态调度系统可以更好地实现基于订阅的支付系统?

我在Django的python中从头开始制作订阅支付系统。我将celery-beat用于RabbitMQ作为队列代理的计划任务。 django_celery_beat使用DatabaseScheduler ...

回答 1 投票 0

防止Celery Beat执行同一任务

我每30秒安排一次芹菜运行任务。我有一个每天作为任务运行,另一个每周在用户指定的时间和星期几运行。它检查“开始...

回答 1 投票 4

Celery beat_schedule使用错误的时区

我正在尝试使用celery beat作为我的Django Web应用程序的一部分运行一项日常任务,该任务调用带有日期字符串参数的函数。节拍时间表运行良好,并在...

回答 1 投票 0

带有动态参数的计划任务与在Django芹菜定期运行

我有一个包含动态参数我要定期运行,我如何通过动态元素的任务参数的任务时,被称为在Django芹菜拍一个任务是什么?这里是任务,我...

回答 1 投票 0

如何在django中从db重新加载整个查询集?

我正在用芹菜来定期完成任务。一个这样的任务从db获取对象的filter:pages = Page.objects.filter(active = True)最初(在启动celery之前)有10个这样的对象......

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.