芹菜调度未触发任务，未报告错误
芹菜调度是一个任务调度框架，用于在分布式系统中管理和调度任务的执行。当芹菜调度未触发任务且未报告错误时，可能有以下几种可能的原因和解决方法：
- 任务配置错误：检查任务的调度配置，包括调度时间、调度频率、任务依赖关系等。确保任务的调度配置正确无误。
- 任务队列堆积：芹菜调度使用消息队列来存储待执行的任务，如果任务队列堆积过多，可能导致任务无法及时触发。可以通过增加消息队列的容量或者优化任务执行速度来解决任务队列堆积的问题。
- 芹菜调度服务故障：检查芹菜调度服务是否正常运行，是否存在异常或错误日志。如果发现服务故障，可以尝试重启服务或者查看相关日志来定位和解决问题。
- 任务执行失败但未报告错误：任务可能在执行过程中出现错误，但由于某些原因未能正确报告错误。可以通过查看任务执行日志或者增加错误处理机制来定位和解决任务执行失败的问题。
芹菜调度的优势在于其灵活性和可扩展性，可以根据实际需求配置和管理各种类型的任务。它适用于各种场景，包括定时任务、异步任务、分布式任务等。对于腾讯云用户，腾讯云提供了一款名为"云函数SCF"的产品，可以与芹菜调度结合使用，实现高效的任务调度和执行。云函数SCF是腾讯云提供的无服务器计算服务，可以帮助用户快速部署和运行任务代码，无需关心底层的服务器运维和扩展。
更多关于云函数SCF的信息和产品介绍，可以参考腾讯云官方文档：云函数SCF产品介绍
相关·内容
我正在处理芹菜时间表任务，遇到了一个问题。 假设有一个计划任务每5分钟运行一次。 这个任务可以在我的一些API中手动执行， 我总是希望这个任务的间隔是5分钟。 例如，如果该任务在8:00自动执行， 在8:01，我第二次执行了这个任务， 现在我希望下一次芹菜自动运行的时间是8:06。 那么有没有办法在芹菜中做到这一点呢？
浏览 12提问于2020-08-21得票数 0
回答已采纳
4回答
我感兴趣的是定期定期运行一组特定的操作。显然，这是的任务，对吗？
不幸的是，互联网似乎存在一些分歧。
让我详细介绍一下我的设置。首先，我的开发环境在Windows中，而我的生产环境则托管在 (Linux)上。Windows上没有真正的cron，对吗？而且，我使用！对Django有什么建议？
当然是！不幸的是，设置芹菜对我来说或多或少是一场噩梦--请看。这只是我在芹菜上遇到的问题之一。其他的包括一个套接字错误，我是唯一一个得到这个问题的人。
别误会，芹菜看起来很酷。不幸的是，它似乎缺乏支持，并且在其首选后端中内置了一些奇怪的限制。不幸的是，不管程序多么酷，如果它不能工作，那么它就不能工作！
我希
浏览 3提问于2011-06-08得票数 11
回答已采纳
1回答
我有以下要求：
我几乎没有大量资源消耗的任务导出不同的报告，这些报表需要大型复杂查询、子查询。
有很多用户。
我在django中构建了项目，并使用芹菜对任务进行排队。
我想限制用户，以便他们可以要求每分钟10份报告。这个想法是，他们可以投入数百个请求10分钟，但我想要芹菜执行10项任务的用户。这样每个用户都能得到他们的机会。
有什么办法可以让芹菜做到吗？
谢谢
浏览 9提问于2015-09-30得票数 0
1回答
我正在使用芹菜作为我的网络应用程序。芹菜执行父任务，然后执行更多的任务。
芹菜问题
我无法从luigi获得依赖关系图和可视化工具来查看我的父任务的状态
芹菜不提供机制重新启动失败的管道，并从失败的地方开始。
这两件事我很容易从路易吉那里得到。
所以我在想，一旦芹菜执行了父任务，然后在这个任务中执行Luigi管道。
这会有什么问题吗?我需要根据队列大小自动调整芹菜工人的规模。这会影响到多台机器上的任何luigi员工吗？
浏览 1提问于2016-05-05得票数 3
回答已采纳
我有一个报告应用程序，它使用芹菜每天处理数千个作业。每种报告类型都有一个python模块，用于封装所有作业步骤。作业采用特定于客户的参数，通常在几分钟内完成。目前，作业是由客户在创建新报告或请求刷新现有报告时按需触发的。
现在，我想添加计划，以便每天运行作业，并自动刷新报告。我知道Airflow在任务编排和调度上大放异彩。我也喜欢将我的工作表达为DAG并从任务重试中获益的想法。我可以看到如何使用Airflow来运行调度的批处理作业，但我不确定我的用例。
如果我将我的作业表示为Airflow DAG，我仍然需要为每个客户运行它们的参数化。这意味着，如果客户创建了一个新报告，我需要有一种方法来触发
浏览 0提问于2020-10-28得票数 0
3回答
有没有办法用芹菜来：
用表单参数对外部URL的HTTP调用排队(HTTP到URL)
外部URL将响应HTTP响应、200、404、400等，如果响应是错误的(非200-ish响应)，它将对一定数量的重试进行重试，并在需要时退出。
使用REST将任务/作业/工作队列添加到芹菜中，传递要调用和形成参数的URL
浏览 0提问于2018-04-02得票数 5
1回答
这里有两项任务。
@app.task(name='add')
def add(x, y):
return x+y
@app.task(name='sub')
def sub(x, y):
return x-y
然后用芹菜链来完成这两个任务。(我使用的版本是4.20)
我想给这串芹菜做计时
我就这样用过：
@app.on_after_finalize.connect
def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(
20.0
浏览 0提问于2019-08-27得票数 1
回答已采纳
1回答
我的django web应用程序逻辑非常适合后台任务的执行(包括周期性的和独立的、同步的和异步的)。所有的研究似乎都指出使用芹菜是最推荐的方法。我计划最终部署在Heroku上，它支持芹菜+ Redis (我正在使用的是本地开发)，这对我来说是一个很大的好处。
然而，我需要比芹菜更广泛的调度能力。我需要一些周期性的任务来运行诸如“运行在这个月的最后一个太阳上”之类的计划。所以我已经在django中实现了我自己的模型，以存储一个重复规则和其他所需的参数。
现在我很困惑如何把我的桌子和芹菜连接起来。理想情况下，我想做的是拥有我自己的作业模型，它有时间表，任务到期时应该运行，以及任务的参数。类似于C+
浏览 3提问于2012-11-30得票数 1
回答已采纳
在django 2.0应用程序中，我有一个名为Document的模型，用于将图像上传并保存到文件系统中。那部分起作用。在芹菜(v4.2.1)任务中，我正在使用对图像执行一些面部识别。我把图像的document_id传递给芹菜任务，这样人脸识别任务就能找到要处理的图像。如果在保存映像后，我从一个face_recognition操作手动调用DocumentAdmin任务，这一切都能很好地工作。
我尝试从我的face_recognition中的(models.signals.post_save, sender=Document)方法调用(models.signals.post_save, sende
浏览 0提问于2018-11-27得票数 4
回答已采纳
我有许多芹菜节点运行在不同的Linux机器上。简化的集群如下所示：
我有一个长期运行的taskA，它从远程文件服务器下载一个(巨大的)文件，我想在taskB在同一台机器上完成它的工作后触发taskB，因为taskA就是在那里下载的文件，基本上是对taskB的输入。我知道芹菜应该是分发的，但在某些情况下，像这样一个真正的分布式解决方案将是昂贵的。
请注意图表中的taskA on nodeA在同一个节点上触发taskB，而在nodeB上运行的taskA在nodeB上触发taskB (运行“父”任务的同一节点)。
apply()不工作，因为我希望在有备用工作进程时(在同一节点上)将taskB(
浏览 0提问于2016-05-09得票数 1
回答已采纳
1回答
我正在继续的Django项目，谁是谁使用芹菜与Mandrill。每天都有报告发送给客户，由于某种原因，三天内没有一封邮件发送，三天后累积并一起发送。由于我是芹菜新手，我想知道如何调试芹菜延迟和错误，流行的命令和执行路径是什么？
浏览 2提问于2016-08-08得票数 0
回答已采纳
我已经在我的django模型中列出了活动列表。我需要发送电子邮件给用户每15分钟，直到活动(如果活动状态:高)完成。
我遵循的步骤如下：
1.创建芹菜任务
2.使用apply_async(eta='time object')触发此任务
3.我在CELERYBEAT_SCHEDULE中注册了此任务
#1.celery task
@shared_task
def periodic_send_email(self, *args, **kwargs):
#Logic for sending email
#2.task triggering
periodic_send_email
浏览 2提问于2018-08-01得票数 0
1回答
我有一个具有多个芹菜节拍任务的Django项目，当我有多个芹菜节拍任务和单独的队列时，我有一个问题，所以我是否有可能一次运行所有这些任务，运行这些任务的最佳实践是什么？
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from celery import Celery
from celery.schedules import crontab
os.environ.setdefault('DJANGO_SETTINGS_MODULE',
浏览 0提问于2018-09-28得票数 1
重新启动芹菜会导致所有周期性任务(芹菜节拍时间表)重新设置，并从芹菜重新启动的时间开始，还是保留计划？
例如，假设我有一个每天下午12点执行的周期性任务。现在我下午3点重新开始芹菜。这个周期性的任务会被重置为每天下午3点运行吗？
浏览 1提问于2021-10-13得票数 0
回答已采纳
1回答
我试图将动态工作流引入到我的领域中，这涉及到不同模型推断的多个步骤，其中一个模型的输出被输入到另一个model.Currently中，很少有芹菜工作人员分散在主机上来管理推理链。随着复杂性的增加，我们正在尝试动态地构建工作流。为此，我得到了一个动态DAG设置和塞勒伊执行器工作。现在，有什么办法我可以保留目前的芹菜设置和路线气流驱动的任务给相同的工人？我理解这些工作人员中的设置应该可以访问DAG文件夹和环境，与气流服务器相同。我想知道如何在这些服务器中启动芹菜工人，这样气流就可以从python应用程序的手动工作流中执行相同的任务。如果使用命令“气流芹菜工人”启动员工，则无法访问应用程序任务。如果
浏览 5提问于2021-05-27得票数 1
回答已采纳
我有两个系统的服务，一个负责处理我的芹菜工人(10个排队等待不同的任务)和一个处理芹菜拍打。
部署新代码后，我重新启动芹菜工人服务，以获得新任务并更新芹菜作业。
我应该重新开始芹菜拍打与芹菜工人的服务吗？
还是自动获得新任务？
浏览 1提问于2017-12-08得票数 1
回答已采纳
1回答
在我的项目中，我有一个芹菜任务，它每30秒由芹菜节拍发送给工人。我想知道芹菜是如何执行芹菜任务的？无论是为每个任务产生一个新线程，还是为task.How产生一个新工作线程，我们都可以知道任务是否完成并从我正在使用RabbitMQ的message broker队列中删除。
浏览 1提问于2017-10-30得票数 1
1回答
我正在尝试执行一个定期任务，使用芹菜来删除那些没有及时激活账户的用户。下面的屏幕截图显示任务被正确发现和执行，但当我检查数据库时，没有进行任何更改。
芹菜任务：
#tasks.py
from celery.task.schedules import crontab
from celery.decorators import periodic_task
from celery.utils.log import get_task_logger
from .utils import unconfirmed_users_delete
logger = get_task_logger(__name__
浏览 0提问于2015-05-06得票数 0
2回答
此查询与我的相关。基本上，我有一个主节点，它将构建任务委托给多个指定的图像构建节点。现在，我使用一个手册，'scp'，通过使用'ssh‘策略的远程执行来完成它。因此，我没有任何调度或任务分配-自动。
我现在正在寻找一个可能比我目前的策略更好的解决方案。我看了一下‘芹菜’，就用它玩了一会儿。我能够远程运行一份简单的工作。然而，据我所知，芹菜需要工作节点上的源文件。我也无法探索芹菜是否会自动完成任务分配/调度？我正在使用RabbitMQ作为代理。
我是新手，所以更有经验的人肯定可以建议芹菜是一个好的选择，还是有更适合这个选择的东西？
浏览 4提问于2012-06-04得票数 0
回答已采纳
1回答
我发了一个问题:
我得到的答案是，芹菜是最简单的选择，但现在我还有一个关于芹菜的问题：
from celery.schedules import crontab
CELERYBEAT_SCHEDULE = {
# Executes every Monday morning at 7:30 A.M
'every-monday-morning': {
'task': 'tasks.add',
'schedule': crontab(hour=7, minute=30, day_of_w
浏览 3提问于2012-08-12得票数 2
回答已采纳
我想在Apache Airflow中根据每个工人的健康和当前负载将工作分配给我的工人。类似于HAProxy leastconn的东西就是我想要的。 有没有办法让员工报告他们的负载/健康状况，并相应地分配任务？我喜欢吃Dask或芹菜，但我最熟悉的是芹菜
浏览 12提问于2019-05-23得票数 1
我使用Redis broker和数据库结果后端( Postgres DB )运行Django芹菜，这与我在主应用程序中使用的相同。
最近，我遇到了这样一种情况: Postgres服务器被重新启动，而工作进程失去了它们的DB连接。在这种情况下，即使DB返回并且主Django站点正常响应，也没有芹菜任务再次成功。在进行任何处理之前，我需要重新启动celeryd进程。所有芹菜任务都报告了相同的错误：
DatabaseError: terminating connection due to administrator command
SSL connection has been closed une
浏览 2提问于2013-08-14得票数 3
回答已采纳
我有一个蟒蛇芹菜-红色的队列处理，上传和下载，一次有价值的演出和演出数据。
很少有上传需要几个小时的时间。然而，一旦完成了这样的任务，我就会看到这种奇怪的芹菜行为，芹菜调度程序再次将刚刚结束的任务重新发送给工作人员(我正在运行一个工人)，并且在同一任务上只发生了2次！
有人能帮我知道为什么会发生这种事吗?我怎样才能阻止它？
这些任务绝对是干净利落地完成的，没有错误报告，只是这些是非常长时间运行的任务。
浏览 0提问于2014-12-05得票数 5
回答已采纳
我已经创建了一个芹菜工人与一个单一的芹菜节拍调度任务，运行时间间隔为5秒。如何在不停止的情况下，动态地向芹菜工人添加另一个节拍任务？
示例
app.conf.update(
CELERY_TASK_RESULT_EXPIRES=3600,
CELERY_TIMEZONE = 'UTC',
CELERYBEAT_SCHEDULE = {
'long-run-5-secs': {
'task': 'test_proj.tasks.test',
'schedule'
浏览 13提问于2015-11-13得票数 6
回答已采纳
我正在Django开发一个web应用程序，我需要每天早上8点向数据库发送一些随机数字。
我试过用芹菜，但没有用。我使用的窗口和一个教程，我知道芹菜不起作用的窗口。
我尝试过使用django扩展和django-cron，但是它需要对linux进行更改，正如我之前所说的，我在windows上。
我该怎么解决这个问题？任何帮助都将不胜感激。
浏览 9提问于2020-10-06得票数 1
回答已采纳
2回答
嗨，我在一个项目上工作，我需要芹菜节拍来运行长期的周期性任务。但问题是，在启动芹菜节拍之后，第一次运行它需要花费指定的时间。 我希望第一次在加载时触发任务，然后定期运行。 我在stackoverflow上看到了这个question，在GitHub上看到了this问题，但没有找到一个可靠的解决方案。 对这个有什么建议吗？
浏览 29提问于2020-07-12得票数 0
回答已采纳
我是异步任务的新手，我正在使用django-celery，并希望使用django-celery-beat来调度周期性任务。
然而，看起来芹菜节拍并不能接受一次性的任务。我是否需要两个芹菜实例，一个作为工人，一个作为一个关闭任务，另一个作为节拍，用于计划任务才能正常工作？
浏览 8提问于2019-07-05得票数 1
@shared_task
def forgot_email(subject,user_cipher,key_cipher,to):
print "comes here in the mail"
try:
email_content = {'user_cipher':user_cipher,'key_cipher': key_cipher}
message = render_to_string('forgot_password.txt',email_content)
send_mai
浏览 3提问于2016-04-04得票数 0
1回答
芹菜的任务每分钟都会停止，但是倒计时从我开始芹菜的时候开始。我是否可以创建一个周期性的任务，它将每分钟执行一次(就像在时钟上)，而与我开始任务的时间无关。
@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(60.0, do_something.s(), expires=10)
现在它是这样工作的，我在10:10:24开始做芹菜(H:M:S)：
do_something - 10:11:24
do_something - 10:1
浏览 3提问于2020-05-21得票数 0
回答已采纳
我有一个使用Quartz Scheduler来调度作业的应用程序。应用程序当前运行的是Quartz版本1.6.2。我的JobStore是有Oracle数据库支持的org.quartz.impl.jdbcjobstore.JobStoreTX。集群已打开，但只有一个调度程序在使用数据库。我的Quartz threadPool配置如下：
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 5
org.quartz.threadPool.threadPr
浏览 0提问于2010-07-24得票数 9
回答已采纳
这两者有什么区别呢？
塞利
芹菜工
塞利波
我试图设置芹菜+主管和一些在网络上的conf文件有多个，而其他只有一个。
浏览 2提问于2013-10-30得票数 43
回答已采纳
2回答
我在django应用程序中有这些行。它们在正常情况下运行得很好，但当我将它们称为芹菜任务时，似乎什么都没有发生。我甚至找不到报告的错误。有没有人能建议我哪里会出错？
cmd = "/path/to/unzipped_s3cmd/s3cmd get s3://%s %s/"
subprocess.call(cmd % (s3path,localpath), shell=True)
我在django用户下运行芹菜任务。
浏览 0提问于2013-07-08得票数 1
1回答
我有一组三台机器。我想对这些运行celery beat。我有几个相关的问题。
芹菜有一个持久性调度器的概念。只要我的计划仅由crontab条目组成，并且是由CELERYBEAT_SCHEDULE静态定义的，那么是否需要持久化它呢？
如果需要，那么必须确保集群的所有机器之间的存储是同步的吗？
djcelery.schedulers.DatabaseScheduler会自动处理并发的拍打守护进程吗？也就是说，如果我只使用DatabaseScheduler运行三个跳动的守护进程，那么我是否可以避免重复的任务？
是否有类似于DatabaseScheduler的东西，但基于MongoDB
浏览 4提问于2012-11-22得票数 1
回答已采纳
1回答
Django请求/响应多线程
、、、、
我应用程序的工作流程是-
User submits a file
On receiving -> process_file()
return response
如果process_file()花费大量时间，这可能导致超时，所以我如何在此之前将response发回，然后处理该文件，然后将所需的输出发送给用户。
我已经检查了django-芹菜，但我认为对于我正在尝试构建的一个小应用程序来说，它相当沉重。
：我在网上搜索了一下，如果有人想用芹菜，这里有一篇很好的博客文章，可以帮你解决这个问题--
浏览 3提问于2015-10-15得票数 1
回答已采纳
1回答
我有一个简单的Python /芹菜应用程序，它在延迟后出现闪存消息的问题。我使用芹菜的delay()函数来调用一个休眠5秒的函数，然后闪烁一条消息。尽管在后台函数中使用了with app.app_context()，芹菜报告：
RuntimeError:在请求上下文之外工作
我也尝试过@copy_current_request_context装饰师，就像提到的那样，但是之后我得到了
RuntimeError:只有当请求上下文在堆栈上时，才能在本地作用域中使用这个装饰符。例如，在视图函数中
app.py:
from flask import Flask, flash, rende
浏览 3提问于2017-05-26得票数 3
回答已采纳
3回答
-多个实例和监视
、、、
我正在使用芹菜构建应用程序，最近我们需要按时运行某些任务。
我觉得芹菜很适合这个，但我没什么问题：
是否有可能运行多个celerybeat实例，以避免任务重复？
如何确保赛利波始终在运转？
到目前为止，我读到的是：和
它看起来应该运行一个单独的celery节拍实例。
我运行的应用程序在AWS弹性豆柄码头容器和芹菜工人也是码头集装箱(所以它是快速扩展时，需要)。
最好和芹菜工人一起进行监督，但这似乎是不恰当的做法。
同时，拥有这一单独的celerybeat实例将需要手动提供/启动和监测。
浏览 6提问于2015-01-27得票数 12
回答已采纳
1回答
避免芹菜重试未注册的任务
、、、、
我们有一个带有芹菜的Django应用程序来处理异步任务。我们使用AWS SQS作为任务代理。
我们最终得到了一个要处理的糟糕任务(删除了任务实现而没有删除芹菜节拍条目)。这导致了以下错误：
Received unregistered task of type KeyError('some_deleted_task').
The message has been ignored and discarded.
一旦我们清理了芹菜节拍条目，我们就继续得到错误~2分钟( SQS上的能见度超时设置为2分钟)。
行为似乎是：
任务添加到队列中，在SQS中作为“可用”
工作人员拿起任
浏览 10提问于2021-10-26得票数 0
1回答
我正在开发一个django web应用程序，它的功能(例如sync_files())需要很长时间才能返回。当我使用gevent时，当sync_file()运行时，我的应用程序不会阻塞，其他客户端也可以很好地连接这个When应用程序并与其交互。
我的目标是让and应用程序响应其他客户，而不是阻止。我不希望有无数的用户连接到我的set应用程序(最多20个连接)，我也不想把它设置成下一个twitter。我的应用程序运行在vps上，所以我需要一些重量轻的东西。
因此，在我上面列出的例子中，当我使用gevent时，使用芹菜是否多余？用芹菜有什么特别的好处吗？我不喜欢用芹菜，因为这是我机器上的另一项服务。
浏览 1提问于2013-09-24得票数 5
回答已采纳
1回答
我有一个定期的芹菜作业，应该在每晚午夜运行。当然，我可以只运行系统，让它通宵查看结果。但我可以看到，在解决潜在问题和能源方面，它将不会非常有效。
在这种情况下，有没有让测试变得更容易的诀窍？
浏览 0提问于2015-08-05得票数 0
2回答
用Flask动态调度芹菜节拍任务
、、、、
我希望能够让我的应用程序的用户使用Celery节拍启动/停止周期性的crontab样式的任务。现在我用芹菜
venv/bin/celery worker -A celery_worker.celery --loglevel=info
我用这个简单的例子运行了芹菜节拍：
@celery.task
def add(x, y):
return x + y
在我的配置文件中：
CELERYBEAT_SCHEDULE = {
'add-every-30-seconds': {
'task': 'app.email.add',
浏览 0提问于2015-06-22得票数 8
rabbitmqctl正确地报告了数千个排队的任务：
$ sudo rabbitmqctl -q list_queues name messages messages_ready messages_unacknowledged
default 13142 13126 16
然而，芹菜报告：
>>> len(app.control.inspect().active()['celery@default'])
4
>>> len(app.control.inspect().scheduled()['celery@default
浏览 3提问于2016-11-29得票数 9
回答已采纳
1回答
我想在Django安排一项任务，它每天都会在医院里运行，我正在考虑用芹菜来安排任务，所以我想知道，不管怎么样，通过芹菜-节拍，我可以通过管理面板执行任务，即使其活动或不活跃，并给出我想要通过我的管理site.Instead执行任务的时间，在我的代码中编写这个任务。
crontab(day_of_week="0,6", hour="0,12", minute=15)
我想通过我的管理面板传递它，以便将来如果我想在其他时间执行我的任务，我可以通过管理面板直接修改它，而不是修改我的代码。
浏览 1提问于2019-05-07得票数 1
1回答
我使用气流版本2.2.2和芹菜作为执行器。这就是我想要达到的目标
Dag应该每秒钟运行一次，一次只运行一个活动的dag。
以前我用芹菜和芹菜解决了这个案子。由于将应用程序移动到基于集群的调度程序，我们正在尝试使用气流。有人能建议我们在这个用例中使用气流吗？
浏览 3提问于2021-12-02得票数 1
1回答
姜戈芹菜，芹菜殴打工人
、、、
在芹菜中，我有三种任务，第一种任务每3分钟执行一次，几乎每1分钟完成一次；第二项任务是周期性的，每周一运行一次，几乎需要10分钟才能完成；第三项也是最后一项任务是发送用户电子邮件以获得注册/忘记密码。我不知道我应该使用多少个工人/芹菜实例，有人能帮我吗？
浏览 6提问于2022-05-11得票数 0
假设我有三台服务器A，B & C，服务器C将有芹菜任务代码，我需要从服务器A&B执行它们。
从芹菜中，我看到有一个作为芹菜工人运行的task.py文件
from celery import Celery
app = Celery('tasks', broker='pyamqp://guest@localhost//')
@app.task
def add(x, y):
return x + y
然后我们有另一个python文件(比方说client.py)，它调用这些任务。
from tasks import add
add.dela
浏览 1提问于2020-04-22得票数 5
回答已采纳
python版本: 3.5.2芹菜版本: 4.1.0
服务器本地时区:亚洲/北京时区+08:00 CST
芹菜设置：
timezone = "Asia/Shanghai"
beat_schedule = {
"test.hello": {
"task": "test.hello",
"args": (),
"schedule": crontab(minute=55, hour=22, day_of_week="Mon,Tue,Wed,
浏览 35提问于2017-08-02得票数 3
1回答
我有一个数量为20的mongodb集合，我用它来存储一些关于我当前正在使用cron作业处理的任务的数据。
在使用cron作业时，我的每个集合都有一个worker。我想改善这种安排，我正在研究芹菜。我希望每个集合至少有4个工作人员，因为我在每个集合中有许多记录。
我希望作业在到达时完成，而不是等待5分钟，因为它在使用cron作业时发生。
我是否有可能在芹菜中以我所描述的方式在每个集合中拥有4个工作人员？
浏览 1提问于2017-09-11得票数 0
5回答
我使用Celery (3.0.15)和Redis作为代理。
有没有一种简单的方法来查询芹菜队列中存在的具有给定名称的任务的数量？
接下来，有没有一种方法可以取消芹菜队列中存在的所有具有给定名称的任务？
我已经通过了，但没有看到解决方案。
浏览 5提问于2013-03-23得票数 37
回答已采纳
1回答
芹菜执行预定任务100次
、、、
我在django应用程序中配置了芹菜，以便每天早上运行任务。任务只需向一组用户发送一封电子邮件。问题是同样的电子邮件被发送了几百次！
这是我的芹菜配置：
BROKER_URL = 'redis://127.0.0.1:6379/0'
BROKER_TRANSPORT = 'redis'
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
from celery.schedules import crontab
CELERYBEAT_SCHEDULE = {
&#
浏览 1提问于2015-03-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
