按名称调用 Django celery 任务

2024-04-02

我需要从models.py调用一个celery任务(在tasks.py中),唯一的问题是,tasks.py导入models.py,所以我无法从models.py导入tasks.py。

有没有什么方法可以仅使用名称来调用 celery 任务,而无需导入它?出于同样的原因(防止循环导入),ForeignKey 字段也实现了类似的操作。


就在这里。

您可以使用:

from celery.execute import send_task    

send_task('my_task', [], kwargs)

确保您的任务函数有一个名称:

from celery import task

@task(name='my_task')
def my_task():
     ...

希望能帮助到你!

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

按名称调用 Django celery 任务 的相关文章

随机推荐

  • PHP5中单例与工厂模式结合

    在 PHP5 中将单例设计模式与工厂方法模式结合使用的最佳方法是什么 我最简单的使用场景是对每种数据库类型仅实例化选择性数据库连接一次 用于数据库连接的单例工厂 class Registry private static objects p
  • rlang:将多个带有...的组传递给gather()

    假设我想计算mean min and max对于自定义函数中任意数量的组 玩具数据如下所示 library tidyverse df lt tibble Gender c m f f m m f f f m f IQ rnorm 10 10
  • 如何以MVVM方式实现单项DragDrop WPF Listview?

    我的 WPF MVVM 应用程序中有两个列表视图 以及其中的 Gridview 在这种情况下 我将如何实现单个项目的拖 放 任何帮助 将不胜感激 谢谢 我制作了一个示例应用程序 您可以在其中了解它如何与 MVVM 配合使用 我有 Items
  • Firestore 批量写入中的 500 项限制算作什么?

    我在云函数中有以下代码 该代码返回错误消息 错误 3 INVALID ARGUMENT 每个请求最多允许 500 次写入 console log projectId doClassifySources Got size output ite
  • 我应该在fragment中哪里调用Rest API

    我正在使用带有 3 个片段的底部导航 在 Home fragment 上 我请求 API 获取数据并在回收器视图中显示 我的问题是每当我切换片段并再次回到 Home fragment 时 它都会重新创建布局 并再次从 API 获取数据 我只
  • console.log 内具有控制台日志输出的函数打印 undefined

    function haha console log haha console log haha Prints haha undefined 是因为如果你没有在函数中指定 return 它将返回 undefined 这就是第二个 consol
  • 表达式解析为未使用的属性

    override func prepare for segue UIStoryboardSegue sender Any if segue identifier toDetails if let indexPath sender as In
  • 从 CDN JS 导入 firebase firestore 不起作用

    我正在从 CDN 导入 Firebase Firestore 以在本地服务器上运行 我按照文档所述将其导入 就在这里 https firebase google com docs web alt setup https firebase g
  • 我应该如何使用 Hibernate 从 JPQL 查询引用内部枚举(在实体内定义)?

    我有一个实体类如下 package stuff Entity class Thing Id GeneratedValue private Long id Basic Enumerated private State state public
  • 如果不存在则创建文件夹路径(从 VBA 保存)

    我在工作表中有一个项目列表 如下所示 我的代码遍历每一行并对供应商进行分组 并将一些信息复制到每个供应商的工作簿中 在此场景中 有 2 个唯一的供应商 因此将创建 2 个工作簿 这有效 接下来我想将每个工作簿保存在特定的文件夹路径中 如果文
  • 带有 nginx 的网络服务器一直工作到创建 .save 文件

    在过去 48 小时内到处进行谷歌搜索以找出为什么我的服务器突然停止工作后 最后 我自己找到了答案 我决定将其发布在这里 供那些在整个周末都在谷歌上搜索如此琐碎事情的人使用 在 nginx 上加载了所有内容 LEMP 工作完美 但后来我尝试进
  • Excel 中的数据整理 - 重新排列列和行

    我有一个巨大的 Excel 数据集 我想重新排列行和列 这是数据的片段 它看起来是什么样子以及我希望它看起来是什么样子 Area Channel Unit Year1 Year2 Year3 Year4 bel dc share 25 36
  • 使用 java11 构建和部署 javafx 应用程序

    我按照以下步骤操作https blog jetbrains com idea 2013 03 packaging javafx 2 applications in intellij idea 121 https blog jetbrains
  • 为什么 SQL Server SET DEADLOCK_PRIORITY HIGH 不被遵守?

    我捕获了 SQL Server 2012 死锁图 使用盖尔 肖的 https www red gate com simple talk sql performance sql server deadlocks by example 查询 显
  • MongoDB C# 连接/断开(官方驱动程序)

    请告诉我如何通过官方 C 驱动程序连接 断开到 MongoDB 问题很简单 乍一看问题很微不足道 但是 1 我是否需要自己调用Disconnect方法 或者它会被诸如Dispose之类的方法关闭 2 每次需要向Mongo发出请求时都需要连接
  • statsmodel 预测开始和结束索引

    我正在尝试实现 statsmodel 包中的预测功能 prediction results predict start 1 end len test exog test 输入 测试和输出预测的日期不一致 前者为2012年1月4日至2012年
  • getter 和 setter 的 Google 样式指南属性

    我对其中的一项建议感到好奇有关属性的 Google Python 风格指南 https google github io styleguide pyguide html Properties 他们在其中给出了以下示例 class Squar
  • SQLite 与 Android NDK

    是否可以在 Android 手机上将 SQLite 与 C 结合使用 我还没有找到任何关于如何实现这一点的文档 只需从以下位置下载 SQLite3 合并源文件 http www sqlite org download html http w
  • 如何将 Xcode 项目转换为使用 ARC(自动引用计数)?

    当我运行 Convert to Obj C 时 它首先运行预检查 我希望预检查忽略一些文件 并且我认为可以在这些文件上设置编译器标志 fno objc arc 但预检查阶段似乎忽略了该标志 并重置了它 所以我真的不知道如何超越预检查 预检查
  • 按名称调用 Django celery 任务

    我需要从models py调用一个celery任务 在tasks py中 唯一的问题是 tasks py导入models py 所以我无法从models py导入tasks py 有没有什么方法可以仅使用名称来调用 celery 任务 而无