如何在python中完成所有芹菜组任务后调用该方法
在Python中完成所有芹菜组任务后调用该方法，可以按照以下步骤进行：
- 导入所需的模块和库：
import celery
from celery import group- 创建一个Celery实例：
app = celery.Celery('your_app_name')- 定义一个任务函数，用于完成芹菜组任务：
@app.task
def your_task_function():
# 任务逻辑代码
pass- 创建一个任务组，将多个任务添加到组中：
task_group = group([your_task_function.s(), your_task_function.s(), ...])- 执行任务组并等待所有任务完成：
result = task_group.apply_async()
result.join()完整代码示例：
import celery
from celery import group
app = celery.Celery('your_app_name')
@app.task
def your_task_function():
# 任务逻辑代码
pass
task_group = group([your_task_function.s(), your_task_function.s(), ...])
result = task_group.apply_async()
result.join()这样，在Python中完成所有芹菜组任务后，你可以调用result对象获取任务执行的结果。注意，以上代码只是一个示例，你需要根据实际情况进行修改和适配。
推荐的腾讯云相关产品：腾讯云函数（Serverless云函数计算服务），它提供了无服务器的函数计算能力，可以帮助你更轻松地开发和管理云端应用。你可以通过以下链接了解更多信息： 腾讯云函数产品介绍
相关·内容
2回答
目前我正在做芹菜组任务，我想在所有任务完成后调用upload_local_directory(Output_file)方法。我尝试了下面的方法，但它没有等待工作完成。job.apply_async()upload_local_directory_into_S3(output_file) make_tmp_
浏览 27提问于2020-11-30得票数 1
回答已采纳
1回答
芹菜任务子进程填满并发插槽？
、、、、
我正在使用CELERYD_CONCURRENCY = 4在队列中运行一系列长时间运行的重芹菜任务(产生多个子进程)。最初，4项任务按其应有的方式启动。然而，当任务完成时，直到更多的任务完成后才开始新的任务，很快芹菜就会将活动任务的数量减少到1或2，直到所有的任务都完成为止(由芹菜花确认)。当我只运行一些简单的<
浏览 4提问于2014-06-17得票数 2
回答已采纳
当我使用芹菜组和链来调度任务时，如下所示组任务可以在多个worker中执行，在所有组任务完成后，sum_task开始执行(可能在另一个worker中)，那么谁能告诉我芹菜是如何知道组任务都完成了，然后启动sum_ta
浏览 1提问于2017-09-12得票数 0
1回答
在链中返回组的芹菜任务
、、、
我正在尝试将芹菜任务设置为Django站点的一部分，该站点由运行处理流水线的多个步骤的celerybeat调用。().s(), spacer.s(), tile.s()) return result我还尝试使get_plot_task_grou
浏览 2提问于2014-11-24得票数 1
1回答
我试图在更新完成后使用chord启动报告更新。，组中的其余任务和回调都不会启动，没有任何错误被发送到任何地方，芹菜工人日志中也没有任何信息。经过检查工人，芹菜检查活动，排定，似乎没有任何等待任务在队列中。
如果标题(组)有2个或更少的元素，就没有问题，组任务完成，回调就会被调用。我试着使用group.link特性来查看会发生什么
浏览 9提问于2022-06-20得票数 0
回答已采纳
我在芹菜中使用了一个Chord来进行回调，当一组并行任务完成执行时，这个回调就会被调用。具体来说，我有一组函数来包装对外部API的调用。在处理结果并在Chord回调中更新我的数据库之前，我希望等待所有这些返回。我希望在所有API调用完成后执行回调，而不管它们的状态如何。
我的问题是，只有当组的子任务没有引发异常时，回调函数才会被
浏览 2提问于2017-10-18得票数 6
1回答
1)芹菜链。这里是一个简单的链，第一个任务执行，将其返回值传递给链中的下一个任务，依此类推。在芹菜服务器端，还是传递给我的应用程序，然后我的应用把它传递给下一个链项目？>>> g(10).get()
[10
浏览 1提问于2016-11-19得票数 1
回答已采纳
1回答
我在python中使用芹菜来执行异步任务。在所有分配给所有工人的任务完成后，我想捕捉它的结果。为此，我使用了.get()方法，但get()的问题是，所有任务都分配给一个同步的工作人员，但我希望将任务分发给所有可用的工作人员。 res = good_bad_urls.delay(url[1])
res
浏览 5提问于2020-01-16得票数 1
回答已采纳
让我解释一下我所拥有的用例：我必须运行1k -100 k任务，这将运行一个模拟(电影)，并将模拟的数据作为一个相当大的小对象(帧)列表，比如每帧10k-100k和1k帧。稍后，我需要从每个框架中计算特征，这可以完全独立地完成。
这些框架看起来像一个dict，它指向一些numpy数组和其他简单的数据，比如字符串和数字，并且具有唯一的标识符UUID。现在，我考虑使用芹菜来获得这些第一部电影，而且由于这些电影最终会出现在后端DB中，所以我可能会无限期地保留这些结果，至少我指定要保留的结果是这样的。另一种可能是不
浏览 4提问于2017-01-11得票数 2
回答已采纳
1回答
如何正确地杀死库伯奈茨环境中容器上运行的芹菜任务？整个应用程序的结构(全部是用Python编写的)如下：A Kubernetes结构，其中一个吊舱运行API，其他吊舱运行芹菜容器，以处理可由API触发的一些长期运行的任务这些芹菜容器是自成规模的。
假设我们调用一个SDK方法，该方法反过来向API发出请求，该API触发在芹菜容器上运行
浏览 0提问于2021-03-25得票数 0
回答已采纳
1回答
是否有任何方法让芹菜重新检查主队列中是否有任何任务可以启动？远程命令add_consumer()会完成这项工作吗？原因:我正在运行几个并发任务，这会产生多个子进程.当任务完成时，子进程有时需要几秒钟才能完成，因此由于并发限制被子进程最大化，因此队列中的新任务永远不会启动。而且，由于芹菜在子进程完成后不会再次检查，队列会在没有活动任务</e
浏览 3提问于2014-07-02得票数 2
我的django项目中的一些视图运行芹菜任务，我想在完成这些任务后检查数据库。我对芹菜任务有一个单独的测试，在那里我不使用.delay()方法来调用它们。主要的问题是，在jenkins工作期间，让芹菜工人工作的最好和最干净的方式是什么？目前，我只是在测试前运行nohup celery -A myqpp worker &，并在作业结束时杀死所有正在运行的芹菜。
浏览 2提问于2015-05-25得票数 0
2回答
我的任务是扫描网络文件系统(可以是远程的)，提取多个文件，对它们进行计算，并将结果(每个文件)推入DB中。我正在把它移到芹菜上，这样就可以把它放大。文件数量可能会变得非常大(1M+)。我不知道应采取何种设计方法，特别是：一个任务获得一个批处理(N个文件的列表)，拉出它们，计算和上传结果。(使用批处理而不是单个文件是为了优化到远程文件系统和DB的连接，尽管在这一点上它是一个纯粹的启发式方法)
显然，一个任务将花费很
浏览 1提问于2017-06-21得票数 0
1)我目前正在开发一个web应用程序，该应用程序公开一个REST，并使用Django和芹菜来处理请求并解决它们。为了解决请求，必须向amqp队列提交一组芹菜任务，以便在工人(位于其他机器上)上执行这些任务。每项任务都是非常密集的CPU，需要很长时间才能完成。我已经配置了芹菜也使用amqp作为结果后端，我使用RabbitMQ作为芹菜的经纪人。
每个任务都返回一个结果，需要随后存储在DB中</e
浏览 1提问于2013-02-06得票数 7
回答已采纳
使用submit按钮，我想在后台运行python文件并在下一页显示内容.但是我的python文件需要一些时间才能取出结果，所以在中间我想在中间放置一个加载html页面.我编写了一些代码，它可以正确地运行python文件，但是我无法在.看看我在views.py中的函数 info = request.POST['info'print('value is ', info)
filename = "xxxxxxxxxxxxx
浏览 0提问于2019-05-15得票数 0
1回答
在我的django应用程序中，用户可以在特定操作上定义一些延迟(以秒为单位)--它被用来模拟网络延迟。 return super().dispatch(request, *args, **kwargs)
如果这样做合适，有什么建议吗？也许还有更好的方法。
浏览 0提问于2018-05-07得票数 0
2回答
我想从Python脚本中开始并停止芹菜工人进程。我用Redis做经纪人和后端。我发出一个Popen命令，从计划工人任务的脚本中启动工作人员： cmd = 'celery worker ' cmd += '--loglevel critical'
浏览 0提问于2018-05-12得票数 0
回答已采纳
我正失去理智，试图找到一种可靠的、可测试的方法来获取给定芹菜队列中包含的任务数量。
我使用Redis作为后端，但我希望有一个独立且灵活的后端解决方案，特别是用于测试。这就是我目前的情况:我定义了一个EnhancedCelery类，它继承了Celery，并添加了几个方法，特别是Celery是我试图正确实现/
浏览 0提问于2020-04-29得票数 6
我在一个AWS ECS集群中运行Python Celery (一个分布式任务队列库) worker (每个EC2实例运行1个Celery worker)，但是这些任务是长期运行的，并且不是幂等的。这意味着当发生自动扩展扩展事件时，即ECS由于任务负载较低而终止运行某个worker的一个容器时，该worker上当前正在运行的长时间运行的任务将永远丢失。理想情况下，ECS scale-in事件将在想要终止的EC2实例中的Celery worker上启动热关
浏览 28提问于2021-02-10得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
