谁在芹菜apply_async(countdown=10)等着
在这个问答内容中，谁在芹菜apply_async(countdown=10)等着是一个具体的代码片段，它是在使用Python编程语言中的Celery框架进行异步任务调度时的一种方式。
具体解释如下：
- 芹菜（Celery）是一个基于分布式消息传递的任务队列，它可以用于处理大量的异步任务。
- apply_async是Celery框架中的一个方法，用于将任务添加到任务队列中等待执行。
- countdown=10表示任务将在10秒后开始执行。
在这个代码片段中，谁在芹菜apply_async(countdown=10)等着的意思是某个任务（可以是函数、方法等）通过调用apply_async方法添加到Celery的任务队列中，并设置了一个倒计时为10秒的延迟，即任务将在10秒后开始执行。
这种方式的应用场景包括但不限于：
- 需要执行耗时较长的任务，但又不希望阻塞主线程或用户请求的场景。
- 需要异步执行的任务，例如发送邮件、生成报表、处理大量数据等。
- 需要对任务进行调度和监控的场景。
对于这个问题，腾讯云提供了一个类似的产品叫做腾讯云消息队列 CMQ（Cloud Message Queue），它是一种高可用、高可靠、高性能的分布式消息队列服务。您可以使用CMQ来实现类似的异步任务调度功能。
更多关于腾讯云消息队列 CMQ的信息和产品介绍，您可以访问以下链接：
相关·内容
并在另一个任务中为此工作队列生成20个任务包 async_call.apply_async( expires=60,
countdown问题是:谁在等待倒计时？它在队列里面吗？或者是在工作进程内(接受任务的工作人员的一些空闲时间)？
浏览 25提问于2019-12-17得票数 1
from celery import task
TaskA.apply_async((func, delay_seconds), countdown=1)
def TaskA(func, delay_seconds): if result: xxx
Test.apply_async((TaskB
浏览 1提问于2018-05-02得票数 0
回答已采纳
1回答
如何让django入睡
、、、
我有一个项目，其中一个客户注册了一个请求，而其他一些客户必须回答他们是否想与他一起实时工作。问题是，如果我使用time.sleep()，我如何让他的客户休眠，直到其中一个客户接受我的请求，整个项目都将休眠 class ConsulationConsumer(WebsocketConsumer):
pass
pass
text_data_json = js
浏览 20提问于2021-08-07得票数 1
1回答
我有一个任务(让我们称之为MainTask)，它是使用apply_async方法调度的，这个任务有一些验证，可以触发另一个任务(SecondaryTask)与eta一起调度。每次MainTask试图使用apply_async方法对SecondaryTask进行调度时，SecondaryTask都会灵巧地运行，覆盖eta参数。some_day)@app.task(bind=True, name="main_task", autoretry_for=(Exception,), default_retry_delay=<em
浏览 1提问于2021-01-14得票数 0
def upload(): do_async_upload.apply_async(args=[checkDouble], countdown更新2: print("1")
send_mail.a
浏览 0提问于2020-01-29得票数 0
回答已采纳
1回答
芹菜和丢失的信息
、、、
下面的代码片段启动了在我的芹菜安装中启动的任务：@app.task(ignore_result=False) except Exception as e:
logger.er
浏览 1提问于2015-07-19得票数 0
我正在使用一个使用芹菜的烧瓶应用程序，我正在用Pytest进行测试。((4, 4), countdown=2) assert r1.get(timeout=10) == 8
def test_celery_tasks_countdown_signatures(celery_app, celery_worke
浏览 4提问于2022-06-01得票数 0
我看了芹菜文档，并尝试了其中的一些东西，但它的工作不像这个例子。timedelta(minutes=5) obj.save() base.add = base.number + numberreturn obj编辑：
我尝试将eta转换为
浏览 8提问于2017-07-13得票数 12
1回答
如何使用芹菜链式任务，使第二个任务在特定时间运行，即10:04 PM task 1 -> task 2(计划在明天上午9点)
浏览 0提问于2019-03-21得票数 0
2回答
我需要让芹菜任务在倒计时后运行，但在某些条件下能够重置倒计时。例如，我想用countdown=15调用apply_async，但是如果在任务执行之前发生了某些事件，我想再次将倒计时设置为15秒。
浏览 3提问于2012-03-07得票数 8
我有一个定制的芹菜任务类，然后在装饰器@celeryApp.task中使用。我使用apply_async执行这些任务。pass@celeryApp.task(base=CeleryTask) pass ( ),
浏览 2提问于2019-07-19得票数 1
回答已采纳
调用以下代码但是，任务将立即在队列上执行。capp.conf.update()
capp.start()
芹菜就是这样称呼的
浏览 3提问于2015-11-20得票数 0
回答已采纳
1回答
我试图添加芹菜在我现有的酒瓶应用程序之上，我已经分享了我的项目文件结构下面。我的项目中没有__init__.py文件。我有任务run_job in jobs.py，但是fromm app.py不能导入我创建的芹菜对象。但是我收到了下面的错误。我相信我是错误的，因为我的项目结构，没有init文件。ImportError:不能导入名称“芹菜” - flask-app/ * tasks.py
* jobs.py我的jobs_name
浏览 0提问于2019-08-01得票数 0
2回答
芹菜限制队列中特定任务的数量
、、、、
我用芹菜3.1.x做两个任务。第一个任务(TaskOne)是在芹菜通过celeryd_after_setup信号启动时排队的：def celeryd_after_setup(*args, **kwargs):运行TaskOne时，它会进行一些计算，然后对TaskTwo进行排队。想象一下以下工作流：
我启动芹菜，因此信号被发射，TaskOne被排队。倒计时(5)之后
浏览 4提问于2015-05-27得票数 2
回答已采纳
3回答
如何延迟芹菜任务的执行？
、、、
我面临的问题是，芹菜工人在脚本将任务排入队列后立即开始拾取任务。这是正确的，这是芹菜应该工作的方式，但这经常导致我的脚本和芹菜工作人员之间的死锁。我在芹菜或django-celery的文档中找不到这一点。这个是可能的吗？
浏览 0提问于2012-10-22得票数 18
回答已采纳
1回答
如果我可以使用countdown特性，并将任务分散到一个可变的秒数上(比如一个小时，3600秒)，那就最好了。我认为我可以添加countdown arg，在我的范围内有一个随机数生成器，这样就可以“打包”并准备好在group中执行单独的任务准备了吗？，看起来signature应该支持countdown>>> signature('tasks.add', args=(2, 2), countdown=<
浏览 0提问于2021-11-30得票数 0
回答已采纳
2回答
在以下几个方面是否有任何区别： result = r.join() r= group(some_task.s(i) for i in range(10))()芹菜文档使用了这两个例子，我看不出有什么不同。
浏览 2提问于2015-10-18得票数 11
我在试着找出芹菜是怎么工作的。我有一个项目，有大约10个app.now我想使用芹菜。import when_task_expiration
result = when_task_expiration.apply_async((2, 2), countdown我尝试替换@shared_task和@app.task(bind=True)，但是没有注意到changed.even，我尝试使用.delay()代替apply_async((2, 2), coun
浏览 8提问于2019-07-10得票数 2
回答已采纳
1回答
Django调度和队列非定期任务
、、、、
我研究过django-芹菜，但所有的文档显示都是任务的定期调度。但是我想要的是添加一个任务来排队，并在一个特定的时间安排它，直到那个时候任务可以进入睡眠状态。而且，它只能执行一次。我对姜戈芹菜的看法正确吗？是否有更好的方法或其他方法来安排非定期任务。
浏览 4提问于2014-12-20得票数 2
回答已采纳
1回答
points): self.save()
我正在使用update_object.delay(object_id, points)调用芹菜任务
浏览 0提问于2019-10-05得票数 0
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
