如何更改芹菜中的键名
How can I change the key names in celery
celery完成一个task后写入redis。不过entry的key是celery自己决定的(我觉得是task id)。我想给出具体的名称,因为其他服务就是这样知道它们的位置的。
在我的代码中,有一个创建任务的生产者和许多工人。
现在我在所有任务完成后使用 tasks_name.get() 并使用我的命名约定创建新的 redis 条目。
但这似乎是不必要和缓慢的。 Celery 应该只使用我的约定。
我正在考虑重命名它们,但如果可行的话。我怎样才能从生产者那里收到 ID。
也许一些自定义的 RedisBackend class 但那太深了。
您可以在提交任务时使用task_id
参数为任务指定一个自定义ID。 Celery class.
的 apply
and apply_async
methods of Celery task and send_task
方法支持它
celery完成一个task后写入redis。不过entry的key是celery自己决定的(我觉得是task id)。我想给出具体的名称,因为其他服务就是这样知道它们的位置的。
在我的代码中,有一个创建任务的生产者和许多工人。 现在我在所有任务完成后使用 tasks_name.get() 并使用我的命名约定创建新的 redis 条目。 但这似乎是不必要和缓慢的。 Celery 应该只使用我的约定。
我正在考虑重命名它们,但如果可行的话。我怎样才能从生产者那里收到 ID。 也许一些自定义的 RedisBackend class 但那太深了。
您可以在提交任务时使用task_id
参数为任务指定一个自定义ID。 Celery class.
apply
and apply_async
methods of Celery task and send_task
方法支持它