如何获得计划的芹菜任务的任务对象

Question

这个问题类似于芹菜队列中的任务列表，但我想获得实际的Task对象(参见http://docs.celeryproject.org/en/lestest/reference/celery.events.state.html＃Celery.events.state.task(，而不是字典表示。

当我做

时

from celery.task.control import inspect
i = inspect()

然后从外壳做i.scheduled()，我得到了

的结果

In [75]: i.scheduled()
Out[75]: 
{'[e-mail]': [{'eta': '2019-08-01T01:31:37.843141+00:00',
   'priority': 6,
   'request': {'acknowledged': False,
    'args': "[126, 'Business Signup', {'actualCompanyName': 'Gilmore and Beck LLC', 'gigsEnabledRegionMapping': True, 'companyName': 'Gilmore and Beck LLC', 'companyRegionMapping': 'Lesliechester', 'companyId': 'ow9DMA8'}]",
    'delivery_info': {'exchange': '',
     'priority': 0,
     'redelivered': None,
     'routing_key': 'celery'},
    'hostname': '[e-mail]',
    'id': '4ecdc400-8421-4a06-babc-98493362ec67',
    'kwargs': '{}',
    'name': 'backend.tasks.task_send_event_to_iterable',
    'time_start': None,
    'type': 'backend.tasks.task_send_event_to_iterable',
    'worker_pid': None}},
  {'eta': '2019-08-01T01:39:21.205879+00:00',
   'priority': 6,
   'request': {'acknowledged': False,
    'args': "('[e-mail]',)",
    'delivery_info': {'exchange': '',
     'priority': 0,
     'redelivered': None,
     'routing_key': 'celery'},
    'hostname': '[e-mail]',
    'id': '294910a3-2323-4fcf-9768-115c1a8c5e06',
    'kwargs': '{}',
    'name': 'backend.tasks.task_send_business_lead_notification',
    'time_start': None,
    'type': 'backend.tasks.task_send_business_lead_notification',
    'worker_pid': None}}]}

我想通过这些任务进行搜索并有条件撤销。但是，我希望迭代结果，并具有方便的实际任务，就像在如何通过任务名称检查和取消芹菜任务的示例中一样。但是，如果我尝试做celery.events.state.State()，我没有任何事件：

In [76]: celery.events.state.State()
Out[76]: <State: events=0 tasks=0>

是否可以为计划任务获取实际的Task对象？特别是，我有兴趣获得args而无需解析或尝试ast.literal_eval()。

Answer 1

我不确定您是否可以实际获取实际的列为实例，但是您可以通过简单地使用要检查的任务ID实例化来轻松创建异步，并且您需要(自然(也将芹菜应用程序对象传递给它。

一些伪代码：

from celery.result import AsyncResult
from my.project.celeryapp import myapp
task_res = AsyncResult("9ed888fe-f6b6-4443-85d3-787c5c1b26b0", app=myapp)
print(task_res.state)