celery redis 密码

在使用Celery连接Redis时，如果Redis设置了密码，需要在连接URL中添加密码信息。可以使用quote()函数对密码进行转义，然后将其添加到连接URL中。例如：CELERY_BROKER_URL = 'redis://mast:{}@xxxx:6379/2'.format(PASSWORD)。另外，在Django项目中配置Redis时，也可以在CACHES中添加PASSWORD参数来设置密码。

相关问题

celery flower 启动如何只指定redis密码

你可以通过在启动命令中使用 `--broker` 参数来指定Redis连接的URL，包括密码。例如：

celery flower --broker=redis://:password@redis_host:redis_port/0

其中，`password` 是你的 Redis 密码，`redis_host` 是 Redis 服务器的主机名或 IP 地址，`redis_port` 是 Redis 服务器的端口号，`0` 是 Redis 数据库编号。

这样，你就可以在启动 Celery Flower 时只指定 Redis 密码了。

celery配置redis集群

以下是配置celery使用redis集群的步骤：

1.安装redis-py-cluster库

pip install redis-py-cluster

2.在celery中配置broker_url

from celery import Celery
app = Celery('tasks', broker='redis://', backend='redis://')

app.conf.broker_url = 'redis+sentinel://<user>:<password>@<sentinel_host>:<sentinel_port>/<service_name>'
app.conf.broker_transport_options = {'master_name': '<service_name>'}

其中，`<user>`和`<password>`是redis集群的用户名和密码，`<sentinel_host>`和`<sentinel_port>`是sentinel的地址和端口，`<service_name>`是redis集群的服务名称。

3.启动celery worker

celery -A tasks worker --loglevel=info