Django Celery RabbitMQ访问被拒绝(403) ACCESS_REFUSED
Django Celery RabbitMQ访问被拒绝(403) ACCESS_REFUSED
问题描述： 在使用Django Celery时，发生了RabbitMQ访问被拒绝的错误，返回403 ACCESS_REFUSED的错误提示。
可能原因： 该错误通常发生在RabbitMQ的访问权限设置方面，表明当前用户没有权限访问所需的队列或交换机。
解决方案：
- 检查RabbitMQ的访问权限设置，确保当前用户有访问所需队列和交换机的权限。
- 确认Celery的配置文件中是否正确指定了RabbitMQ的相关信息，包括主机名、端口号、用户名和密码等。
- 检查RabbitMQ服务是否正常运行，确保RabbitMQ服务已启动并监听指定的端口。
- 确保Django应用中的Celery配置文件正确导入了RabbitMQ的相关配置，例如导入了正确的VHOST。
- 尝试重新启动Celery Worker和Celery Beat进程，以确保配置的更新生效。
- 如果您使用了防火墙或安全组，确保已经打开了与RabbitMQ通信所需的端口。
- 如果您的应用程序运行在容器化环境中，确保容器网络配置正确，容器内的RabbitMQ可以通过指定的端口访问。
- 可以尝试使用RabbitMQ的管理界面或命令行工具查看当前用户的权限设置，以确认是否正确配置了访问权限。
- 如果问题仍然存在，您可以参考腾讯云提供的消息队列 CMQ（Cloud Message Queue）来替代RabbitMQ。CMQ是一种高可用、高可靠、高性能的消息队列服务，具备良好的云端兼容性和稳定性。
腾讯云相关产品： 腾讯云提供了多种与消息队列相关的产品和服务，可以满足不同场景的需求：
- 云消息队列 CMQ：腾讯云的云消息队列CMQ是一种高性能、可靠、安全的分布式消息队列服务，适用于构建弹性、可扩展和可靠的应用程序。
- 云函数 SCF：腾讯云的云函数SCF是事件驱动的无服务器计算服务，可以与云消息队列CMQ进行集成，实现消息的消费和处理。
以上是关于Django Celery RabbitMQ访问被拒绝(403) ACCESS_REFUSED的问题的一些解决方案和腾讯云相关产品的介绍，希望对您有帮助。
相关·内容
1回答
我用的是Django 1.10和芹菜4号。
我在芹菜的文件中发现了漏洞：
工作人员配置做得很好，运行良好(我可以看到在RabbitMQ webmin中连接的工作人员)。但是我的任务不能连接到RabbitMQ来发布他们的消息。
settings.py
CELERY_BROKER_URL = 'amqp://dev:dev@localhost/dev_virtualhost'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZE
浏览 6提问于2016-12-23得票数 4
回答已采纳
1回答
我正在尝试让Django Celery worker连接到RabbitMQ服务器，所有这些都运行在同一主机上。
但是，当我运行manage.py celery worker时，我得到的结果是：
[2013-06-11 17:33:41,185: WARNING/MainProcess] celery@localhost has started.
[2013-06-11 17:33:44,192: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 2 seconds...
[2013-06-
浏览 1提问于2013-06-12得票数 21
回答已采纳
我有一个与heroku集成芹菜的django项目。我已经通过heroku获得了rabbitmq附加组件，并在本地测试了我的任务是否成功。我遇到的问题是将我的远程服务器连接到rabbitmq/cloudamqp。 我相信我使用的凭据是问题的罪魁祸首，但我不确定我错在哪里。我正在使用通过cloudamqp仪表板提供的凭据。这包括： AMQP URL
User & Vhost
Password 在我的settings.py中，我有： CELERY_BROKER_URL= "amqp://{User}:{Password}@{AMQP URL}:5672/" 我已经尝试了各种
浏览 457提问于2020-04-16得票数 0
错误:握手由服务器: 403 (访问被拒绝)终止，并显示消息"ACCESS_REFUSED -登录被拒绝使用普通身份验证机制。有关详细信息，请参阅broker日志文件。“我单独尝试了authMechanism ('PLAIN'，'AMQPLAIN'，'EXTERNAL')，但是我得到了同样的错误。无法创建与rabbitMQ的连接
var raabitmqSettings = {
protocol: 'amqp',
hostname: '10.250.18.31',
port: 567
浏览 0提问于2018-07-11得票数 2
我使用Django和芹菜和RabbitMQ作为消息代理。在Windows环境下开发时，我在Django内部安装了RabbitMQ并配置了芹菜，如下所示：
celery.py
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'main.settings')
app = Celery('DjangoExample')
app.config_from_object('django.conf:settings', n
浏览 2提问于2021-02-24得票数 1
回答已采纳
我不能运行芹菜工人+码头+姜戈。我下载了图像兔和链接的工人，在运行时我得到错误:无法连接到amqp://guest:**@127.0.0.1:5672//: Errno 111连接被拒绝。worker_1。Django: 1.11，日历: 4.1.0。哪里做错了？
docker-compose
rabbit:
image: rabbitmq:latest
ports:
- "5672:5672"
worker:
build: ./project
volumes:
- ./main:/src/app
depends_on:
- rab
浏览 1提问于2018-05-08得票数 8
我有芹菜在Ubuntu20.04上运行，RabbitMQ作为代理。
芹菜多次重新启动，因为它无法访问RabbitMQ url (RABBITMQ_BROKER)，这是一个保存在Django根目录的外的settings.py 中的变量。
如果我试图通过命令行启动芹菜，也会发生同样的情况。
我已经确认了这个变量可以通过views.py打印语句从views.py内部访问。
如果我将RABBITMQ_BROKER变量放置在Django根芹菜works中的settings.py中。
我的问题是，当变量RABBITMQ_BROKER放在/etc/opt/mydjangoproject/setings.py
浏览 2提问于2021-11-02得票数 0
回答已采纳
1回答
我正在尝试创建带有芹菜任务的django apache服务器并使用rabbitmq作为message brooker的文件。我的问题是芹菜和兔子没有联系。我得到了那个错误：
2021-02-1808:11:44,769: ERROR/MainProcess使用者:无法连接到amqp://来宾：**@rabbitmq:5672//: Errno 111连接被拒绝。
这也是我第一次建立码头图像，所以我可能犯了很多错误。
我的船坞-撰写文件：
version: "3.8"
services:
server: &server
build:
cont
浏览 1提问于2021-02-18得票数 3
=错误REPORT==== 18-2018年8月-2018年：：11:38:19连接<0.17949.0>上的===信道错误(IP:50872 -> IP:5672，vhost：'myhost'，user：'myuser')，信道1：{amqp_error，access_refused，在vhost 'myhost‘拒绝用户“用户”，'exchange.declare'}
下面是我现在面临的错误。
我已经运行了AWS实例，拍摄了一个快照，并在上面放置了新的django代码。在上面运行芹菜任务，并在rabbitmq
浏览 1提问于2018-08-18得票数 0
我正在码头集装箱中运行Django、芹菜和RabbitMQ。
但是，当我试图安装django-celery-beat时，在初始化服务时遇到了问题。
具体而言，此命令：
celery -A project beat -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler
导致此错误：
celery.platforms.LockFailed: [Errno 13] Permission denied: '/usr/src/app/celerybeat.pid'
查看原因/解决方案时，当默认调度程序(ce
浏览 3提问于2020-04-18得票数 0
回答已采纳
1回答
我第一次将一个远程工作者连接到我的芹菜服务器(Django)。在我的服务器上，我为用户创建了一个新的用户名和密码，并设置了权限：
# rabbitmqctl add_user adcelery pwd
# rabbitmqctl set_permissions adcelery "^adcelery-.*" ".*" ".*"
# rabbitmqctl list_users
Listing users ...
guest [administrator]
adcelery []
...done.
# /etc/init.d/rabbit
浏览 4提问于2014-01-12得票数 2
回答已采纳
目前，我正在尝试连接到rabbitmq，但我收到以下错误。异常'PhpAmqpLib\Exception\AMQPProtocolConnectionException‘，消息为'ACCESS_REFUSED -登录被拒绝，使用身份验证机制AMQPLAIN。有关详细信息，请参阅broker日志文件。
我已经工作了几个小时了，不知道如何解决这个问题。rabbitmqbundle使用的凭据也被其他应用程序(python/pika)使用，这些应用程序连接到rabbitmq没有问题。代理日志文件也没有提到任何失败的身份验证尝试。此外，正在使用的配置在登台/生产环境中工作良好，所有这些都
浏览 0提问于2015-10-13得票数 0
我正处于例外状态
org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED -登录被拒绝使用身份验证机制。有关详细信息，请参阅代理日志文件。
配置: windows上的RabbitMQ 3.3.5
在%APPDATA%\RabbitMQ\rabbit.config中的Config文件上，我按照做了以下更改
[{rabbit, [{loopback_users, []}]}].
我还试着创建一个用户/pwd
浏览 39提问于2014-11-07得票数 120
回答已采纳
1回答
当使用芹菜、码头、RabbitMQ和Django (与django-celery-results和django-celery-beat一起使用)时，我能够按照加载一个简单的任务。
但是，当我对任务进行更改并重新加载服务器(docker-compose down、docker-compose up)时，这些更改不会得到反映。芹菜是否在某个地方缓存任务/如何在开发环境中重新加载它们？本教程设置了CELERY_CACHE_BACKEND = 'django-cache'，但我假设这是由docker-compose down销毁的
例如，在CELERY_BEAT_SCHEDULE中从t
浏览 1提问于2020-04-18得票数 1
3回答
我在EC2上的两个实例上创建了一个rabbitmq集群。我的django应用程序使用芹菜来执行异步任务，而异步任务则使用RabbitMQ作为消息队列。
每当我用命令开始芹菜的时候：
python manage.py celery worker --loglevel=INFO
或
python manage.py celeryd --loglevel=INFO
我一直收到与远程RabbitMQ相关的错误消息：
[2015-05-19 08:58:47,307: ERROR/MainProcess] consumer: Cannot connect to amqp://myuser:**@&l
浏览 0提问于2015-05-19得票数 2
回答已采纳
我在两个linux服务器上有一个带有两个rabbitmq节点的集群主机。我希望设置第一个动态铲子，将消息从节点1的“SourceQueue”路由到节点2的“DestinationQueue”。
因此，我使用rabbitmq-plugins命令在两个节点上启用rabbitmq_shovel和rabbitmq_shovel_management插件，然后根据web浏览器从RMQ web管理中找到铲子状态和铲子管理菜单。
但是，当我试图从RMQ管理网站添加一个名为“FirstShovel”的新sholve时，我得到了下面的错误消息。
auth_failure，"ACCESS_REFUSED
浏览 3提问于2016-09-04得票数 1
回答已采纳
由于一些复杂的原因，我的spring启动应用程序需要在Rabbitmq服务器启动之前启动。
使用spring boot initializer生成一个简单的带有AMQP的spring boot app，添加相应的配置并@RabbitListener监听某个队列。
如果Rabbitmq服务器已经运行，则app与服务器连接成功；
如果应用程序先启动，然后启动Rabbitmq服务器，日志会按重复多次的顺序显示以下异常，然后应用程序退出
--没有到主机的路由
--连接被拒绝
--ACCESS_REFUSED
我也检查了评论，但没有找到解决方案。
有没有办法让spring boot app尝试连接rab
浏览 3提问于2019-06-12得票数 0
1回答
我对使用c#的狂犬病很陌生。我们正在尝试为epex spot创建一个API，它在传输标签协议中使用AMQP，并为此使用Rabbitmq。
我能够连接到epex spot的服务器使用提供的证书。能够创建通道的ConnectionFactory factory = new RabbitMQ.Client.ConnectionFactory();
using (IConnection conn = factory.CreateConnection())
{
using (IModel channel = conn.CreateModel())
{
但是，每当我尝试DeclareExc
浏览 0提问于2018-10-02得票数 2
我正在尝试设置我的Django应用程序，使其具有推送通知功能。对于调度通知，我尝试使用芹菜，对于message，我选择了RabbitMQ。我的应用程序运行在Docker容器中，我很难让RabbitMQ正常工作。在运行Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 111] Connection refused.时，我会得到一个错误消息docker-compose up。下面是我的celery和rabbitmq3服务，它们来自于我的docker-compose.yml
celery:
restart: always
浏览 12提问于2021-10-21得票数 4
回答已采纳
1回答
我知道“来宾”用户是RabbitMQ的默认用户，但我认为我已经配置了所有的东西以使用不同的名称。
我的堆栈是Django / Celery / RabbitMQ，在Docker中运行。
首先，每隔几秒钟我就会收到大量的错误：
rabbitmq_1 | 2020-07-29 08:28:00.775 [warning] <0.1234.0> HTTP access denied: user 'guest' - invalid credentials
rabbitmq_1 | 2020-07-29 08:28:05.775 [warning] &
浏览 4提问于2020-07-29得票数 2
回答已采纳
我开始使用rabbit.js从一个node.js应用程序连接到RabbitMQ。
我被封锁的原因是：
错误:服务器关闭通道: 403 (拒绝访问)，并带有“默认交换不允许的ACCESS_REFUSED -operation”消息
在(/.../rabbit.js/node_modules/amqplib/lib/channel.js:398:24)的Channel.C.accept公司
Connection.mainAccept 公司
在(/.../rabbit.js/node_modules/amqplib/lib/connection.js:448:48)的Socket.go公司
Soc
浏览 8提问于2014-07-24得票数 40
回答已采纳
2回答
我们使用Vault数据库后端(MySQL和RabbitMQ)安装了，它使我们能够将生成的凭据注入到属性中，如：
spring.rabbitmq.username
spring.rabbitmq.password
当我们的应用程序启动时，我们有了一套新的兔子凭证，并且我们有能力按需请求一个新的集合。
因为我们的兔子证书是由Vault外部管理的，所以在应用程序生命周期的任何时候，它们都可能过期/删除(这也是一个复原力测试场景)。
我的问题是，我们如何(有效、可靠)：
检测生成的凭据的过期。
用新的凭据更新现有的Spring CachingConnectionFactory。
浏览 0提问于2018-03-07得票数 1
回答已采纳
我在一个django项目中使用芹菜和rabbitmq，在这个项目中，我创建了两个队列，queue_email和queue_push，与一个工作人员一起运行。
但是rabbitmq也有以下队列，默认情况下创建：
celery
celery.pidbox
celeryev
reply.celery.pidbox
如何以及为什么要创建这些默认队列？
如果没有必要的话，他们能被移除吗？
浏览 3提问于2017-06-30得票数 2
回答已采纳
我在试着找出芹菜是怎么工作的。我有一个项目，有大约10个app.now我想使用芹菜。
setting.py：
CELERY_BROKER_URL = 'amqp://rabbitmq:rabbitmq@localhost:5672/rabbitmq_vhost'
CELERY_RESULT_BACKEND = 'redis://localhost'
我使用以下信息在rabbitmq中创建了一个用户：username: rabbitq和password:rabbitmq。然后，我创建了一个名为rabbitmq_vhost的vhost，并为其添加了rabbitmq权
浏览 8提问于2019-07-10得票数 2
回答已采纳
我在芹菜容器上出了个差错。
芹菜-敲打错误日志：
[2018-11-27 12:40:21,139: WARNING/MainProcess] (0, 0): (403) ACCESS_REFUSED - Login was refused using authentication mechanism AMQPLAIN. For details see the broker logfile.
[2018-11-27 12:40:21,241: WARNING/MainProcess] Sentry is attempting to send 1 pending error messages
[
浏览 1提问于2018-11-27得票数 4
Docker-compose.yml
version: "3"
services:
web:
# replace username/repo:tag with your name and image details
image: sunilsuthar/sim
deploy:
replicas: 5
resources:
limits:
cpus: "0.1"
memory: 50M
restart_policy:
condit
浏览 61提问于2018-08-03得票数 1
尝试在14.04部署一个多节点openstack Juno。以下是我的魅力配置文件：
nova-cloud-controller:
openstack-origin: cloud:trusty-juno
network-manager: "Neutron"
openstack-dashboard:
openstack-origin: cloud:trusty-juno
keystone:
openstack-origin: cloud:trusty-juno
glance:
openstack-origin: cloud:trusty-juno
cinder
浏览 0提问于2014-11-24得票数 0
我试图建立我的气流使用码头和rabbitMQ。我用的是兔am :3-管理图像。我能够访问rabbitMQ UI和API。
在气流方面，我正在建设气流网服务器，气流调度器，气流工作者和气流花。Airflow.cfg文件用于配置气流。
我使用的是broker_url = amqp://user:password@127.0.0.1:5672/和celery_result_backend = amqp://user:password@127.0.0.1:5672/
我的停靠器撰写文件如下
version: '3'
services:
rabbit1:
image:
浏览 2提问于2017-06-22得票数 17
回答已采纳
我得到错误"'DisabledBackend‘对象没有属性'_get_task_meta_for'"../
这是django settings.py
# celery settings
CELERY_RESULT_BACKEND = 'amqp'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
这是celery.py
from __future
浏览 0提问于2017-02-22得票数 0
回答已采纳
我有Django项目，我不能访问/查询PostgreSQL从芹菜。它会影响任何表，即使它存在。查询在Celery之外运行得很好，所以我可能在Celery配置中做了一些错误的事情。不接触数据库的芹菜任务工作得很好。
错误消息：
Traceback (most recent call last):
File "/usr/src/app/accounts/tests.py", line 28, in test_access_to_database
result_output = task.get()
File "/usr/local/lib/python3.8
浏览 0提问于2020-06-21得票数 0
我设法让Django、RabbitMQ和Celery在单机上工作。我听从了的指示。现在我想让他们一起工作，但是当他们在不同的服务器上时。我不希望Django知道任何关于Celery的事情，也不希望Celery了解Django。
因此，基本上，我只想在Django中发送一些消息到RabbitMQ队列(可能是id、任务类型，或者其他信息)，然后我希望RabbitMQ (如果可能的话)将该消息发布到另一个服务器上的Celery。Celery/Django不应该相互了解，基本上我想要一个很容易替换其中任何一个的体系结构。
现在，我的Django中有几个电话，如
create_project.apply
浏览 3提问于2014-12-21得票数 1
回答已采纳
1回答
我使用Django-Celery +rabbitmq来执行一些异步任务，我定义了一个队列'sendmail‘来执行发送邮件任务，发送邮件是由特定的任务触发的(这个任务有自己的队列)，但是现在我遇到了一个问题，在特定的任务完成后，邮件有时会立即发送，有时需要5-20分钟，我想知道是什么原因造成的。
当调用task.delay()时，Django-celery会将任务名和参数作为消息打包到rabbitmq。
我想知道消息什么时候到达rabbitmq，但是使用web管理工具只能看到总消息，不能看到每条消息的详细信息，特别是消息到达的时间。Django-celery日志只能看到从代理时间和执行
浏览 0提问于2012-06-24得票数 0
我已经把Celery和Django安排好了。我使用RabbitMQ作为我的经纪人。我正在尝试使用一个独立于Django数据库的sqlite数据库将sqlalchemy设置为我的结果后端。我已经运行了RabbitMQ、Django和Celery，没有任何问题。我放入我的settings.py CELERY_RESULT_BACKEND = 'db+sqlite:///celery_results.sqlite3' &在Celery worker启动时，它在日志输出中显示配置正确的后端。
问题是我的数据库没有被创建。为什么会发生这种情况？
浏览 4提问于2016-07-09得票数 0
回答已采纳
1回答
/opt/fubar/fubar/celery.py
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'fubar.settings')
app = Celery('f
浏览 2提问于2020-07-27得票数 0
我正在使用Celery+redis运行一个用于异步任务的应用程序。我设法弄到芹菜--见任务清单。然而，我的任务不是由芹菜工人执行的，而是由Django过程执行的。
我尝试使用.delay()和.apply_async()调用任务，但没有成功(实际上，在这些情况下，对任务的调用被无限期地阻止，日志中没有显示任何内容)。
我可能错过了一些非常基本的东西，但看不清在哪里。
相关设置如下：
settings.py
CELERY_REDIS_DB = os.environ.get("REDIS_DB_CELERY", 0)
CELERY_REDIS_HOST = os.getenv(&#
浏览 1提问于2021-11-02得票数 0
回答已采纳
我有一个Django应用程序，它使用django-celery和rabbitmq后端。我们有一个测试机器，其中不同的用户在他们自己的帐户中运行相同的Django应用程序(每个用户监听不同的端口)，但所有用户都使用相同的settings.py文件，因此使用相同的rabbitmq凭据来将celery连接到后端。(请注意，它们各自使用不同的sqlite数据库作为db后端)。
我刚刚发现，我们可能在django-celery任务之间出现了“串扰”，用户A的帐户中的django应用程序的任务请求可能由用户B的帐户中运行的celery任务提供服务。
要避免这个问题，最简单的配置方法是什么？我是否需要为每个
浏览 2提问于2012-02-23得票数 1
回答已采纳
我已经在一个Ubuntu20.04Sever上设置了一个用于生产的测试Django环境，使用下面的指南：。
具体而言，我将Django项目置于：
/opt/mydangoproject/
celery.py
celery_config.py
settings.py
etc
我还有一个额外的“重写”settings.py，它保存“秘密”--特别是在本例中--芹菜登录变量RABBITMQ_BROKER位于：
/etc/opt/mydangoproj
浏览 5提问于2021-11-01得票数 0
1回答
我正在Fedora 19上安装Openstack，我删除了RabbitMQ默认用户“来宾”，并创建了一个名为“演示”的新用户。在所有的nova.conf i配置rabbit_userid=demo中。但是连接到本地主机:5672失败。从rabbitmq日志中，RabbitMQ仍然使用默认用户“来宾”来连接。我试图在rabbitmq.conf中设置default_user“演示”，但它没有work.Why，如何解决？以下是错误日志：
{handshake_error，启动，0，{amqp_error，access_refused，"AMQPLAIN登录拒绝:用户‘来宾’-无效凭据“，‘
浏览 3提问于2014-11-15得票数 0
2回答
我配置了一个Celery 4.1 worker来处理来自名为"longjobs“的队列中的任务，使用RabbitMQ作为我的消息传递后端。
我的芹菜配置和工作程序是通过Django 1.11项目管理的。
任何东西都不会抛出任何错误，但是从我的Django应用程序启动的任务永远不会被我的worker拾取。
我的celery.py文件如下所示：
from __future__ import absolute_import
import os
import sys
from celery import Celery
from celery._state import _set_curren
浏览 0提问于2017-11-10得票数 1
我不能用芹菜和WSL打开插座。
请参阅以下信息：
celery -A proj report输出
software -> celery:3.1.26.post2 (Cipater) kombu:3.0.37 py:3.6.7
billiard:3.3.0.23 py-amqp:1.4.9
platform -> system:Linux arch:64bit, ELF imp:CPython
loader -> celery.loaders.app.AppLoader
settings -> transport:pyamqp re
浏览 2提问于2019-01-23得票数 5
回答已采纳
我需要通过Django web界面执行PERL脚本。
用户将选择脚本的参数并执行它。
我想知道是否可以使用Celery/RabbitMQ将这些脚本作为Celery任务执行？
如果是这样，我需要修改PERL脚本吗？我是否必须将RabbitMQ代码写入PERL脚本？或者，我应该只执行Celery任务并等待脚本完成处理吗？我想让脚本更新Django用户/芹菜。
浏览 1提问于2013-11-05得票数 0
所以标题有点长，但我想我的问题解释得很好。
我有一个Django项目，通过使用芹菜和RabbitMQ从另一个网站抓取货币数据，每60秒更新一次模型。当我在本地运行芹菜工人时，它工作得很好，但是当我部署到Heroku时，模型不会更新。
当我检查日志()时，它会显示任务正在运行，但它们没有更新数据库模型。我认为这一定是由于我的settings.py文件中的一些配置错误，但我尝试了无数的解决方案，但没有任何工作。我也尝试用Redis代替，并经历了同样的问题(它在日志中运行良好，但实际上并没有更新数据库)。
以下是我认为可能导致问题的相关代码。
Settings.py (当使用rabbitMQ时)：
浏览 14提问于2022-01-30得票数 0
回答已采纳
我犯了一个错误:现在这两个队列都显式地绑定到某个exchange，我可以对每个队列进行编辑。其中一个队列必须绑定到默认交换。现在，当我试图将队列的交换更改为空字符串时，它会抛出一个异常：
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=403, reply-text=ACCESS_REFUSED - operation not permitted on the default exchan
浏览 7提问于2020-05-27得票数 2
回答已采纳
我有一个Django应用程序，其docker映像的Dockerfile如下所示：
FROM python:3.7
ENV PYTHONUNBUFFERED 1
RUN mkdir /code
WORKDIR /code
COPY requirements.txt /code/
RUN pip3 install -r requirements.txt
COPY . /code/
ENV PORT=8000
EXPOSE 8000
然后，我有一个docker-compose.yml文件，用于为Django应用程序定义其他容器映像和依赖项，如下所示：
version: '3'
浏览 2提问于2020-06-01得票数 0
我可以有多台机器来执行django分发的任务并返回消息吗？我查看了celery/rabbitmq，我不确定是否可以在远程计算机上设置celery工作人员。有人能带我到这里来吗？如果这是不可能的或非常困难的，有什么替代的解决方案吗？
浏览 0提问于2012-01-19得票数 2
2回答
我正在尝试开发一个由监听器组成的应用程序，该监听器将事件发送到RabbitMQ，芹菜从队列中提取事件。
在本地运行所有组件时，我的应用程序可以正常工作。如果我的侦听器在本地运行，并且所有其他组件都在Docker容器中运行，它也可以工作。但是，如果我还在容器中运行侦听器，那么Celery不会接收任何事件。
该应用程序基于Django，与Celery的连接如下所示：
app = Celery('mini_iot')
app.config_from_object('django.conf:settings', namespace='CELERY')
a
浏览 1提问于2018-08-08得票数 0
我在我的windows 7机器上安装了"erlang“和"rabbitmq”。但是当我试图运行这段代码时，我得到了一个异常。
package com.rabbitmq;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class SendMessage {
private final static String QUEUE_NAME = "hello"
浏览 1提问于2016-04-11得票数 16
2回答
我不能让我的芹菜工人不断地听默认队列。芹菜不断地出口。
$: docker-compose up
Starting tasker_rabbitmq_1
Starting tasker_celery_1
Attaching to tasker_rabbitmq_1, tasker_celery_1
tasker_celery_1 exited with code 1
rabbitmq_1 |
rabbitmq_1 | RabbitMQ 3.6.1. Copyright (C) 2007-2016 Pivotal Software, Inc.
rabbitmq_1
浏览 7提问于2016-06-16得票数 6
我在Celery上有一个基于Django的服务，使用RabbitMQ作为代理。我想在同一台机器上安装几个环境。
为每个环境配置Celery的最佳方式是什么？为每个环境提供自己的虚拟主机，因此测试环境将使用ampq://celery:celery@localhost:5672/test，开发环境将使用ampq://celery:celery@localhost:5672/dev
或者使用相同的RabbitMQ虚拟主机并将每个环境定向到不同的队列-这样开发环境的默认队列是default.dev，测试环境的默认队列是default.test
或者设置两个RabbitMQ实例？
浏览 1提问于2013-05-03得票数 0
回答已采纳
我有Django应用程序，它使用芹菜，并使用RabbitMQ作为消息代理。我将抓取数据的项目与刮取数据的项目分开，并希望将这些废弃的数据推入rabbitMQ，这样django将通过芹菜使用这个RabbitMQ消息。我需要帮助来使用从scrapy项目中推入rabbitMQ的消息。
代码片段。
刮痕
def process_item(self, item, spider):
publish_message(item)
return item
def publish_message(data):
import pika
connection = pika.B
浏览 9提问于2022-05-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
