django - 带有 Celery 的 Redis 键的自定义前缀

Question

我正在使用 Redis 作为 Django 和 Celery 之间的代理。我有权访问的 redis 实例与许多其他应用程序共享，因此代理不可靠(它使用的 redis key 被其他人删除，消息经常发送给其他应用程序中的工作人员)。换redis数据库也没有解决问题(数据库少，应用多)。

如何将 Celery 配置为使用自定义字符串作为它使用的所有键的前缀？文档提到了向队列名称添加前缀的方法，但这不会影响 redis 键。据我所知，底层库 (Kombu) 似乎不允许用户为其使用的键添加前缀。

Answer 1

为所有 Redis 键添加前缀的功能已作为 this 的一部分添加.现在你可以像这样配置它:

BROKER_URL = 'redis://localhost:6379/0'
celery = Celery('tasks', broker=BROKER_URL, backend=BROKER_URL)
celery.conf.broker_transport_options = {'global_keyprefix': "prefix"}