当前位置: 首页 > 面试题库 >

在Celery中给定task_id的情况下检索任务结果对象

颜修为
2023-03-14
问题内容

task_id将从celery.result.AsyncResult中将储存在数据库中,并将其与任务影响的项目相关联。这使我可以执行查询以检索task_id与特定项目有关的所有任务。

因此,task_id从数据库中检索到后,我该如何检索有关任务状态/结果/等的信息?


问题答案:

从芹菜常见问题解答:

result = MyTask.AsyncResult(task_id)
result.get()


 类似资料:
  • 问题内容: 我一直在尝试遵循Celery的“ Celery第一步与后续步骤”指南。我的设置是Windows 7 64位,Anaconda Python 2.7(32位),已安装的Erlang 32位二进制文​​件,RabbitMQ服务器和celery(带有)。 按照指南,我创建了一个带有 init .py,tasks.py和celery.py的proj文件夹。我的 init .py是空的。这是ce

  • 问题内容: 问题 我已经将一个长期运行的任务划分为多个逻辑子任务,因此我可以在每个子任务完成时报告结果。但是,我正在尝试报告将永远无法完成的任务的结果(而不是不断产生价值),并且正在使用现有的解决方案来做到这一点。 背景 我正在为我编写的某些Python程序构建Web界面。用户可以通过Web表单提交作业,然后返回查看该作业的进度。 假设我有两个函数,每个函数都可以通过单独的形式进行访问: :执行大

  • 问题内容: 如何检查一项任务是否在celery中运行(特别是我在使用celery-django)? 我已经阅读了文档,并且已经在Google上进行了搜索,但是看不到类似以下的呼叫: 我的用例是我有一个外部(java)服务来进行代码转换。当我发送要进行代码转换的文档时,我想检查运行该服务的任务是否正在运行,如果没有运行,请(重新)启动它。 我相信我使用的是当前的稳定版本2.4。 问题答案: 每个对象

  • 问题内容: 我正在尝试使用pyodbc处理一个非常大的查询,我需要遍历所有行,而不必使用fetchall()一次加载所有行。 是否有一个良好且有原则的方法来做到这一点? 问题答案: 当然,请使用循环。 http://code.google.com/p/pyodbc/wiki/Cursor#fetchone

  • 我决定在我最近开始的项目中使用JPA 2.1的实体图功能,但我遇到了一个问题。 当您将图形扩展到 ManyToOne 关系上时,效果很好,但对于 OneToMany,结果会重复,因为我的提供程序(Hibernate)使用左外连接。 我看到一些解决方案,他们提出了独特的关键字来解决这个问题,但我认为这是一个棘手的解决方案,即使我们如何才能让下一级实体不同。 我的意思是,如果我有3个实体A、B和C,我

  • 我正在构建一个DynamoDB表,并且遇到了如何最好地构建索引的问题。我需要执行3个查询。 我的桌子: 以下是我需要实现的3个查询: 获取单个项目 现在我做一个getItem 作品伟大。 SQL: 如果我做这个本地索引,那么效果很好: SQL: 这是一个给我带来麻烦的问题。我想查询我的数据,并将其按日期排序返回。但是,我需要使用另一个字段作为范围进行查询。因此,如果我添加createdAt作为我的