芹菜和兔子MQ 我没有收到我的任务更新

Question

你好吗？我正在研究 django 2.2、芹菜 4.4.2 和 在我的 tasks.py 文件中，我有以下代码

@shared_task
def start_task(dict):
objectLogic = LogicProcess()
# print('dict', dict)
task = objectLogic.RunProcess(parameters=dict)
print("Estado de la tarea: {}r".format(task))
return task

它调用一个函数，最后我更新它但没有收到响应。

current_task.update_state(
state = 'PROGRESS',
meta = {
'current': oer_number,
'total': TotalOER,
'percent': int((oer_number * 100) / TotalOER)
}
)

啊是的...在任务结束时，我让它返回

return {'current': TotalOER, 'total': TotalOER, 'percent': 100}

好吧，如果我得到一个(第一次更新(，我看不到其他的

celery -A ost worker -l info -n worker
task 528454cb-724e-48bc-b95e-9d3a124b22e1
Task status     {}
task 528454cb-724e-48bc-b95e-9d3a124b22e1
Task status     {'state': 'PROGRESS', 'result': {'current': 2, 'total': 66, 'percent': 3}}

或

task_id=528454cb-724e-48bc-b95e-9d3a124b22e1 HTTP/1.1" 200 2
task_id=528454cb-724e-48bc-b95e-9d3a124b22e1 HTTP/1.1" 200 74
task_id=528454cb-724e-48bc-b95e-9d3a124b22e1 HTTP/1.1" 200 110

或者只是它调用的那个，如果它有效，它只是不返回我的状态

在tasks.py和function.py导入的两个文件中

from celery import shared_task, current_task

该文件包含 celery.py

# from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'ost.settings')
app = Celery('ost', backend='amqp')
# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# namespace='CELERY' means all celery-related configuration keys
# should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')
# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

在django看来，我是这样称呼的

from celery.result import AsyncResult
task = start_task.AsyncResult(task_id)
data = {}
if isinstance(task.result, dict):
data['state'] = task.state
data['result'] = task.result

我用if task.ready()试过了，但它不符合条件，尽管我已经提到它是否结束函数并返回

无论如何，我不知道还能指出什么，任何想法都会被测试，我审查的一些东西链接 1、链接 2、链接 2

PS：我在for循环中更新任务状态

Answer 1

正如我提到的，更新是在 FOR 周期内进行的，为此我做了一个AsyncResultRecursive functions，在我的例子中是 django 视图。这将检索任务的状态。当oer_number = TotalOER时，我结束它(task.state = SUCCESS(。

看到有透视的东西是合乎逻辑的，它会在FOR周期中更新，它会在recursive functions毫米内恢复，人们会忘记的事情。所以它只恢复一个值