如何使用 Django admin 使用 Celery 创建自定义任务

Question

我有一个为房地产公司创建的 Django 后端。我已经构建了很多硬编码的任务，我想通过管理页面自定义这些任务......但我无法弄清楚如何做到这一点。

例如，假设我想创建一个任务来发送可以从管理页面自定义的电子邮件。理想情况下，我会有一个可供选择的触发器列表，例如提交联系表单。

看起来像这样的东西：

Answer 1

我多次遇到同样的需求，解决方法如下：

1. 我有一个抽象的“基础”任务模型，其中包含任何“通用”后台任务共有的几个字段：created_on、started_on、completed_on、status、progress、failure_reason 等等
2. 当需要新的特定任务时，我会写：
   • 由调度程序运行的作业功能（在您的情况下为 Celery）
   • 从 Task 派生的具体模型
3. 派生模型知道必须运行哪个作业；这是在模型定义中硬编码的； 我还添加了特定字段来收集作业所需的任何自定义参数
4. 现在，您可以通过编程方式或从 Django 管理员创建新任务，并根据需要提供实际参数；在后一种情况下，Django 照常提供所需的表单和验证

在数据库中保存新记录后，模型开始工作，传递任务（模型）id； 您可以从作业中检索任务的详细信息：这是原始问题的答案。 您还可以更新模型中的进度/状态以供以后检查，并使用基类提供的其他服务（例如日志记录）。

此架构已被证明非常有用，因为作为额外的好处，您可以从 Django 管理员监控异步任务。

在多个项目中使用过它，我将这个逻辑封装在一个可重用的 Django 应用程序中：

https://github.com/morlandi/django-task

当前的实现基于rq，因为Celery 针对我的需要进行了过度设计。我想它可以通过一些修改适应Celery：

• 移除 Task.check_worker_active_for_queue()
• 移除 Task.get_queue()
• 重构Task.run()

此外，辅助作业类必须重构如下：

• 将 rq.get_current_job() 替换为 Celery 的等效项

很遗憾，最近没用过Celery，无法给出更详细的建议。