如果任务处于挂起状态或当前正在执行,您可以看到任务的参数。最简单的方法是使用 celery 检查方法。
from celery.task.control import inspect
i = inspect()
active_tasks = i.active()
reserved_tasks = i.reserved()
scheduled_tasks = i.scheduled()
您可以迭代它们,并通过使用任务 id,您可以获取所有任务详细信息,如下所示
{'acknowledged': True,
'args': '(1000,)',
'delivery_info': {'exchange': '',
'priority': 0,
'redelivered': None,
'routing_key': 'celery'},
'hostname': 'celery@pavilion',
'id': '30d41ba2-3e71-49ce-8e7d-830ba1152256',
'kwargs': '{}',
'name': 't.wait',
'time_start': 1007.945882783,
'type': 't.wait',
'worker_pid': 10560}
或者,您也可以从代理读取数据,将其反序列化,然后获取任务参数。