如何延迟芹菜不存在的任务？

Question

我有两个环境
1. 网络服务器
2.芹菜工人

web 服务器将作业添加到 celery 消息队列。但是这些环境是分开的，所以不能导入任务函数。

如何显式调用不存在的任务？

例如）

# A project (web) - view.py
def view(request): 
    [X] task_a.delay()  
    [O] add_jobs("task_a", *args)
    ...

# B project (worker) - tasks.py
@task
def task_a:
    ...

Answer 1

使用 send_task function 将任务发送到解耦的芹菜项目。

from celery.app import Celery
app = Celery(broker_url='the broker url of the celery instance')
app.send_task(name='myapp.mytaskname', kwargs={
  'arg1': 'value1',
  'arg2': 'value2',
})

如何延迟芹菜不存在的任务？

How to delay not exist task by celery?

python

django

celery