Celery试图连接到错误的经纪人
我的Celery配置中
BROKER_URL = 'redis://127.0.0.1:6379'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379'
但是，每当我运行celery时，都会出现此错误
consumer: Cannot connect to amqp://guest@127.0.0.1:5672//: [Errno 111] Connection refused. Trying again in 2.00 seconds...
为什么它不连接到我正在运行的Redis代理，而后者正在运行？
问题答案：
导入您的Celery并像这样添加您的经纪人：
celery = Celery('task', broker='redis://127.0.0.1:6379')
celery.config_from_object(celeryconfig)
该代码属于celery.py
-
当尝试在 CentOS 上使用 Python 客户端本地连接到 Kafka 0.10.0.0 时，我有一个非常奇怪的问题。 我的连接选项非常简单且默认： 当我在Kafka的服务器中手动设置侦听器选项时。属性文件，如： 我得到了kafka.errors。NoBrokersAvailable，尽管我仍然可以使用curl或其他linux工具轻松连接到Kafka代理服务器。 无广告。侦听器或其他不推荐使用
-
我在一个django应用程序中运行我的芹菜工人的任务，每个任务需要大约1-2秒来执行。通常这些执行是好的，但有时，特别是如果Django应用程序已经部署了一段时间，我开始看到这样的错误： 这向我表明芹菜工人没有正确关闭连接。 发生此错误时，我检查了DB上的空闲连接计数——肯定还有一些连接剩余，所以没有达到DB的最大连接限制。 我的问题：如何确保芹菜工人正在关闭数据库连接？ 芹菜设置： 我的Djan
-
我有一组Kafka代理实例作为集群运行。我有一个客户正在生产数据给Kafka： 当我们使用tcpdump进行监控时，我可以看到只有到broker1和broker2的连接被建立，而对于broker3，没有来自我的生产者的连接。我有一个只有一个分区的单一主题。 我的问题是: > 为什么在我的情况下，我无法连接到broker3？或者至少我的网络监控没有显示我的制作人与broker3建立了连接？ 如果我能
-
我正在尝试通过PDO连接到php中的Oracle 11g Express Edition数据库。我安装了xampp，我还有一个（据推测）正常工作的pdo_oci扩展，它也出现在phpinfo（）中。我的数据库工作正常，我可以通过sql控制台和/或sql开发人员连接到它。我已经启用了扩展php_pdo_oci。动态链接库 我的代码是： 我得到以下错误： 致命错误：未捕获异常“PDOException
-
无法解析Android应用程序模块的Gradle配置。请解决gradle构建问题和/或重新同步。
-
我想为我的芹菜Que（Rabbitmq）获取统计数据。我正在使用celery.app.control.检查（）. stats（）API。我在网络服务器上做这件事，我只能得到一次统计数据。如果我刷新页面，我得到[Errno 104]连接重置由对等错误。我怎么能处理这个。 /初始化。派克 /帮手。派克 每当有请求"get_stats"功能被命中。它只适用于在此之后的第一个请求，它说通过对等错误重置连接