如何使用Django/Celery接收调用多个任务并收集任务状态
Django是一个基于Python的开源Web应用框架，而Celery是一个Python分布式任务队列，两者可以结合使用来接收调用多个任务并收集任务状态。
使用Django/Celery接收调用多个任务并收集任务状态的步骤如下：
- 安装Django和Celery：首先确保已经安装了Python和pip，然后使用pip安装Django和Celery库。
- 创建Django项目：使用Django的命令行工具创建一个新的Django项目。
- 配置Celery：在Django项目的配置文件中，添加Celery的配置信息，包括消息代理（如RabbitMQ或Redis）、任务队列和结果存储等。
- 定义任务：在Django项目中创建一个tasks.py文件，定义需要执行的任务函数。每个任务函数使用装饰器
@task来标记为Celery任务。 - 调用任务：在Django的视图函数或其他地方，通过调用Celery的
delay()或apply_async()方法来触发任务的执行。可以传递参数给任务函数。 - 收集任务状态：可以使用Celery提供的异步结果对象来获取任务的执行状态和结果。可以通过异步结果对象的方法，如
ready()、successful()、get()等来判断任务是否完成和获取任务的结果。 - 监控任务：可以使用Celery提供的监控工具，如Flower来监控任务的执行情况，包括任务的状态、执行时间等。
Django/Celery的优势在于可以实现任务的异步执行，提高系统的并发性能和响应速度。它适用于需要处理耗时任务的场景，如发送邮件、生成报表、处理大数据等。
推荐的腾讯云相关产品是腾讯云容器服务（Tencent Kubernetes Engine，TKE），它提供了强大的容器编排和管理能力，可以方便地部署和管理Django/Celery应用。TKE支持自动伸缩、负载均衡、容器日志管理等功能，可以提高应用的可靠性和可扩展性。
更多关于腾讯云容器服务的信息，请访问：腾讯云容器服务
相关·内容
2回答
如何使用Django/Celery接收调用多个任务并收集任务状态
django、task、celery、status
我正在tasks.py中设置多个任务，并从views.py调用这些任务。我想在for循环中调用所有不同的任务，这样我就可以轻松地收集状态并构建进度条。目前我可以逐行调用所有任务(如下所示)。下面是我的问题:如何在for循环中从views.py调用不同的任务？它总是给我一个错误"unicode没有属性delay()“。或者，有没有更好的方
浏览 26提问于2018-12-21得票数 0
回答已采纳
1回答
芹菜并行任务处理错误“没有结果后端配置”
django、celery、django-celery
尝试使用3名工作人员运行一些并行任务，并使用以下方法收集结果：jobs = group(celery_calculate_something.s(id):无论我如何尝试，在对结果调用get()时总是得到相同的结果：
No result backend configured.但是，结果后端已经配置好了--我还有许多
浏览 2提问于2014-12-05得票数 1
2回答
在远程任务中使用Django结果后端
python、django、rabbitmq、celery
我有一个使用Celery创建异步任务的Django应用程序。其中一些任务位于Django项目中，另一些任务位于具有自己的代码库的远程工作人员中。我目前使用django-celery-results包将任务调用的结果存储在Django数据库中，这样我就可以使用Django ORM轻松地查询调用的状态</e
浏览 17提问于2019-01-21得票数 2
2回答
使用教程无法工作Django芹菜Kombu
python、django、celery、amqp、kombu
试着让它工作: Django 1.6.11 +芹菜3.1.19 + Kombu 3.0.33在Ubuntu14.04上使用教程，所以我从这里完全重复了项目结构：在我的应用程序vk_wall中，我有带有add任务的tasks.py文件。=10) res_add = add.delay(2，2))
我还安装了django-芹菜来查看管理面板
浏览 2提问于2016-01-17得票数 2
1回答
姜戈与芹菜:从正在进行的任务中获得地位
django、celery、django-celery、celery-task、djcelery
使用crontab设置一个定期任务，以运行以下任务add：import使用Django shell，我可以获得以下内容：>>> from extractionapp.models import Manager
>>> Manager.objects.a
浏览 3提问于2015-05-25得票数 1
回答已采纳
2回答
如何在运行时创建芹菜队列，以便发送到该队列的任务被工人捕获？
django、queue、celery、amqp、worker
我用django 1.4，芹菜3.0，狂犬病queue_name = 'content.{}'.format(content.pk)
# E.g. queue_name = content然而
浏览 5提问于2014-02-10得票数 4
回答已采纳
1回答
为什么AsyncResult在任务完成后返回NoneType？
python、rabbitmq、django-celery
问题问题描述'NoneType‘对象没有属性
浏览 3提问于2015-08-06得票数 1
3回答
Celery任务状态始终处于挂起状态
python、django、celery、django-celery、celery-task
我是芹菜和django的新手，所以请原谅我缺乏知识。我正在尝试运行一个测试来做一些计算，并等待测试完成，这样我就可以确保它是为正确的答案完成的。not calculate.AsyncResult(c.id).status == "SUCCESS": passfrom celeryshared_task
def calculate(proj_id):
#some calculations follow
浏览 3提问于2014-06-11得票数 19
回答已采纳
2回答
如何将我的Django函数设置为从onclick按钮在后台运行？
python、django、asynchronous、background-process、pythonanywhere
我有一个Django项目，其中一个函数当前在我的html上运行- def follow(request):
except Exception:
return render(request, "followed.html") 该函数运行并跟踪授权用户的追随者有没有办法转移到followed.html上并</em
浏览 49提问于2020-12-29得票数 2
回答已采纳
1回答
当定义多个任务时，如何获得芹菜任务类型的任务状态和结果？
asynchronous、celery、task、celery-task
通常，我用定义的承诺的.apply_async方法发送异步任务，然后使用同一个对象的AsyncResult方法上的taskid来获取任务状态，并最终得到结果。但这要求我知道在同一部署中定义了多个任务时的确切任务类型。当我可以知道任务状态和结果(如果可用的话)而不知道确切的任务时，有什么方法可以避免这种情况呢？#!但是在检查任务状态时
浏览 4提问于2022-04-24得票数 0
回答已采纳
1回答
从不同的服务器调用芹菜任务
django、celery
我在一个服务器上有一个django应用程序+ redis，在另一个服务器上有芹菜。我想调用django应用程序的芹菜任务。:6379/0'
def test():从Django服务器调用芹菜任务：我正在使用这个命令来运行芹菜工人：
celery</
浏览 2提问于2022-09-29得票数 1
2回答
芹菜找不到主动的任务(当地和赫鲁库)
django、python-3.x、heroku、celery
我正试图在Heroku上部署一个应用程序，我使用芹菜和Redis来管理后台任务。我目前有一个后台任务，通过FTP收集数据并将其放入数据库。我也有一个加载页面，定期刷新直到任务完成。但是，我无法检索活动任务的列表(从celery.task.control检查不返回任何任务)。我尝试在本地运行这个程序，我可以看到芹菜接收到了任务(在终端中)。我尝试重新安装了几个库，并确保正确设置了settings.py
浏览 0提问于2019-08-25得票数 1
回答已采纳
1回答
Jobtastic/Celery/RabbitMQ - AsyncResult总是挂起
python、django、rabbitmq、celery
我正在使用Django，芹菜和Jobtastic来尝试设置一些任务，我将在我的主要set应用程序上轮询这些任务。我使用RabbitMQ作为我的代理。问题是，虽然任务在启动Celery后正常显示，但尝试获取状态如下所示： if request.is_ajax():我的终端显示任务已经完成，但我仍然处于挂起状态。我已经尝试将下面CELERY
浏览 25提问于2017-07-08得票数 0
2回答
芹菜拍打是发送适当的任务，但任务没有得到执行。
python、django、celery、django-celery、django-celery-beat
问题陈述:芹菜节拍正在按时发送预定的任务。但是，工作人员无法接收并执行任务。我正在使用以下芹菜版本celery==4.4.0这个命令被用来敲打芹菜。celery -A project_path.dev beat -l info --scheduler django_celery
浏览 11提问于2022-07-04得票数 0
1回答
调用其他任务时更新芹菜配置。
celery、django-celery、celery-task、djcelery、celeryd
我使用RabbitMQ代理作为不同的django应用程序执行多个任务。这是用标准django配置设置的，并且运行得很好。我使用组，链，从不同的模块调用他们。作为一种标准做法，我有：app = Celery('<proj>')app.autodisc
浏览 6提问于2016-04-09得票数 0
3回答
芹菜和transaction.atomic
django、postgresql、transactions、celery
在一些Django视图中，我使用类似这样的模式来保存对模型的更改，然后基于新的模型数据执行一些异步更新(例如生成图像，进一步更改模型)。mytask是一个芹菜任务： mymodel.save()问题是任务永远不会返回查看celery的日志，任务进入队列(我在日志中看到“已接收任务”)，但它永远不会完成。如果我将mytas
浏览 0提问于2014-11-15得票数 18
回答已采纳
2回答
解耦和Dockerize Django和芹菜
django、docker、celery、django-celery
我想知道从Django解耦芹菜的最好方法是什么，以便将这两个部分对接并使用？通常，用户使用引用Django应用程序的命令启动他们的芹菜工人和芹菜节拍：celery beat -A my_app
由此，我相信celery会从设置文件和celery.py文件中提取配置信息，这很容易移动到微服务中。我不完全理解的是这些任务将如何利用Django</
浏览 5提问于2017-01-17得票数 6
2回答
如何将django请求中的值传递给芹菜中的周期性任务？
python、django、web-applications、celery
我有一个关于如何从Django运行参数并将参数传递给芹菜任务的问题。1从提交的表单中获取关键字(hashtagName)谢谢!正如在
浏览 0提问于2014-07-22得票数 2
1回答
Django &芹菜路由问题
django、celery、django-celery、kombu
我使用Django和芹菜，并尝试设置路由到多个队列。当我指定一个任务的routing_key和exchange (无论是在任务装饰器中还是使用apply_async())时，任务不会添加到代理(它连接到我的MySQL数据库)。如果我在任务装饰器中指定队列名(这意味着路由密钥被忽略)，则任务可以正常工作。这似乎是路由/交换设置的问题。
知道有什么问题吗？'kombu.transport.dj
浏览 2提问于2012-05-22得票数 9
回答已采纳
1回答
芹菜/瓶update_state不改变状态
python、celery
我的烧瓶配置如下CELERY_RESULT_BACKEND = "redis://127.0.0.1这就是召唤任务的路线。apptask.apply_async(args=["d"]) print(ts.info)
浏览 4提问于2022-10-27得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
活动推荐
腾讯云开发者
