Celery-通过命令行或HTTP请求激活任务

Question

我的代码中有一个预定义的芹菜任务，比如my_proj.tasks.my_celery_task

我想通过命令行/HTTP请求（而不是通过我的应用程序）激活任务。

我搜索了文档（查看了flower和curl选项），但没有一个调用预定义任务的好例子。如何做到这一点？

Answer 1

假设您已经使用Rabbitmq安装了Celery，下面是一个简单的示例。

定义任务：my_app.py

from celery import Celery
app = Celery('tasks', backend='amqp', broker='amqp://')
@app.task
def add(x, y):
    return x + y

启动工人：

celery worker -l info -A my_app

启动花朵

flower -A my_app

通过命令行将任务添加到队列

curl -X POST -d '{"args":[1,2]}' http://localhost:5555/api/task/async-apply/my_app.add

或通过请求

import requests, json
api_root = 'http://localhost:5555/api'
task_api = '{}/task'.format(api_root)
args = {'args': [1, 2]}
url = '{}/async-apply/my_app.add'.format(task_api)
print(url)
resp = requests.post(url, data=json.dumps(args))
reply = resp.json()
reply

Answer 2

您可以使用芹菜命令行

调用任务

# Positional arguments
celery call my_celery_task --args='[1,2]' --broker <broker_url>
# Keyword arguments
celery call my_celery_task --kwargs='{"x":1, "y":2}' --broker <broker_url>
# Returns the task-id

获取结果

celery result <task_id> --result-backend <backend_url>

---

您应该在芹菜应用程序中选择相同的代理和后端集。