如何更改celery 中的关键字名称

mbjcgjjk  于 2021-06-07  发布在  Redis
关注(0)|答案(1)|浏览(383)

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

nkkqxpd9

nkkqxpd91#

您可以使用 task_id 提交任务时的参数。它由 apply 以及 apply_async celery 任务与方法 send_task celery 类的方法。

相关问题