tworzę vhost:Dostęp odmówił użytkownika RabbitMQ & selera
rabbitmqctl add_vhost test
Następnie użytkownik:
rabbitmqctl add_user user 123456
Wtedy biorę uprawnienia do tego użytkownika:
rabbitmqctl set_permissions -p test user "test" "test" "test"
używam seler, w tasks.py:
app = Celery('tasks', broker='amqp://user:[email protected]/test', backend='amqp://user:[email protected]/test')
Potem uruchom:
celery -A tasks worker --loglevel=info
mam błąd:
amqp.exceptions.AccessRefused: Exchange.declare: (403) ACCESS_REFUSED - access to exchange 'celeryev' in vhost 'test' refused for user 'user'
Jak to naprawić?
Dzięki!
Dzięki. Próbuję z 'celeryev' w set_permissions i mam błąd z wymiany' reply.celery.pidbox', więc teraz używam ". *" I to działa. Czy to oszczędza, czy muszę użyć wyrażenia regularnego "seler"? – tim
wyrażenie regularne musi pasować do nazwy kolejki/giełd, które planujesz utworzyć. –