python - 用户 rabbitmq 和 celery 的访问被拒绝

Question

我创建虚拟主机:

rabbitmqctl add_vhost test

然后用户:

rabbitmqctl add_user user 123456

然后我获取该用户的权限:

rabbitmqctl set_permissions -p test user "test" "test" "test"

我在 tasks.py 中使用 Celery:

app = Celery('tasks', broker='amqp://user:123456@localhost/test', backend='amqp://user:123456@localhost/test')

然后我运行:

celery -A tasks worker --loglevel=info

我有错误:

amqp.exceptions.AccessRefused: Exchange.declare: (403) ACCESS_REFUSED - access to exchange 'celeryev' in vhost 'test' refused for user 'user'

如何解决？

Answer 1

在这里查看 set_permissions:https://www.rabbitmq.com/rabbitmqctl.8.html#Access_control

当您调用 set_permissions 时，您正在通过配置、读取和写入的“测试”，因此您的用户将只能使用名为“test”的队列/交换

另外，也请查看此链接:https://www.rabbitmq.com/access-control.html