Truy cập từ chối cho người dùng RabbitMQ & cần tây

Question

tôi tạo vhost:

rabbitmqctl add_vhost test 

Sau đó, người sử dụng:

rabbitmqctl add_user user 123456 

Sau đó, tôi lấy quyền người dùng:

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

tôi sử dụng cần tây, trong tasks.py:

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

Sau đó, tôi chạy:

celery -A tasks worker --loglevel=info 

Tôi có lỗi:

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

Làm thế nào để khắc phục điều đó?

Cảm ơn!

Answer 1

Hãy xem set_permissions đây: https://www.rabbitmq.com/man/rabbitmqctl.1.man.html#Access%20control

Khi bạn gọi set_permissions bạn đang đi qua "thử nghiệm" cho cấu hình, đọc và viết, vì vậy người dùng của bạn sẽ có thể chỉ sử dụng một hàng đợi/trao đổi bằng cái tên " test"

Ngoài ra, hãy nhìn vào liên kết này cũng như: https://www.rabbitmq.com/access-control.html

Answer 2

Nếu bạn vẫn còn có lỗi xin vui lòng kiểm tra xem bạn có dấu ngoặc kép đúng (xảy ra với tôi)

".*" 

01.

thay vì

“.*” 

Để chắc chắn, danh sách cho phép từ người dùng trong vhostpath của bạn (theo mặc định /)

rabbitmqctl list_permissions -p/