完成一项任务后,celery 将其写入redis。但是,条目的键是由celery 本身决定的(我认为它是任务id)。我想给出具体的名字,因为这是其他服务知道他们的位置。在我的代码中,有一个生产者创建任务和许多工人。现在,我在所有任务完成后使用tasks\u name.get(),并使用我的命名约定创建新的redis条目。但这似乎是如此不必要和缓慢。celery 应该用我的习惯。我正在考虑重新命名他们,但如果这是可行的。我怎样才能从生产商那里得到身份证。可能是一些定制类,但这太深了。
nkkqxpd91#
您可以使用 task_id 提交任务时的参数。它由 apply 以及 apply_async celery 任务与方法 send_task celery 类的方法。
task_id
apply
apply_async
send_task
1条答案
按热度按时间nkkqxpd91#
您可以使用
task_id
提交任务时的参数。它由apply
以及apply_async
celery 任务与方法send_task
celery 类的方法。