问题标签 [kombu]

我正在按照本教程让 celery 和 django 在 heroku 上运行。

但是，当我为工作人员输入指定的代码时，我在日志中收到此错误：

我的 settings.py 看起来像

当我在添加此行之前同步时CELERY_RESULT_DBURI = DATABASES['default']，它运行良好。根据文件

当您部署 Django 应用程序时，编译过程会将以下代码附加到您的 settings.py 以使用 DATABASE_URL 环境变量：

我在 Django 工作并安装了 django-celery。celery 守护进程正在我的本地服务器上运行并接受/执行任务。

我的最后一部分是创建一个任务，将消息发送到另一台服务器上的 AMPQ 代理。代理配置在我的 settings.py 文件中，但我不清楚如何连接到 AMPQ 服务器并构造消息（带有标头和 json 编码的有效负载。

现在我开始怀疑我是否需要运行 celery 只是为了向外部 AMQP 代理发送消息。

更新：

我正在使用 Kombu 发布到 AMQP 代理，看来我可以使用正确的交换、routing_key 和 exchange_type 成功建立发布者连接。我的消息必须包含一个带有三个键值对的标头和一个 json 编码的有效负载。我不清楚如何构建消息。

将我的消息有效负载编码为 json 后，我试图通过以下方式发布到代理：

django 正在返回以下内容：

我将 Celery + Kombu 与 Amazon SQL 一起使用。目标是能够删除已经为某个特定日期时间安排的任务。我试过了

但这并没有改变任何东西。是否没有为 SQS 传输实施撤销？它背后是否有一些设计决策，或者它只是一个应该由一些“DeleteMessage”代码行来实现的缺乏功能？

我将我的 celery 从 2.4.X 升级到 celery-2.5.2，然后将 Broker_URL 修改为

此配置可以通过http://docs.celeryproject.org/en/latest/getting-started/brokers/sqlalchemy.html#broker-sqlalchemy的页面引用

Celery 进程可以成功启动，但是我打电话给 . delay或apply_async进程将抛出异常KeyError : 'No such transport: mysql' 我对此一无所知.. 看起来一切都应该是正确的。

追溯

回溯（最近一次通话最后）：

我正在使用 Django 和 Celery，并且正在尝试设置路由到多个队列。当我指定任务的routing_keyand exchange（在任务装饰器中或使用apply_async()）时，该任务不会添加到代理（即 Kombu 连接到我的 MySQL 数据库）。

如果我在任务装饰器中指定队列名称（这意味着路由键被忽略），任务工作正常。这似乎是路由/交换设置的问题。

知道问题可能是什么吗？

这是设置：

设置.py

任务.py

启动任务：

我是我最近部署的kombu/celery 设置。任务执行良好，但似乎几乎连续运行，而不是尊重 run_every 属性。也许更奇怪的是，这种行为只出现在生产中并且在本地运行良好。

我的tasks.py样子是这样的：

我的settings.py包括

加上'djcelery'和'kombu.transport.django'在INSTALLED_APPS。

在生产中，我python manage.py celeryd -v 2 -B -s celery -E -l INFO开始运行我的任务。如果可以解决其他问题，我一直在关注 Chase Seibert 的教程。

芹菜工作正常，有一天命令行工作人员无法启动以下跟踪：

跟踪代码显示“amqp”神秘地失踪了kombu.transport.TRANSPORT_ALIASES——但这就是我失去踪迹的地方。

我想向管理员发送通知电子邮件，例如，如果帖子是垃圾邮件，那么管理员应该收到电子邮件。我正在使用 django-celery templated_email 和 kombu。但是当我运行 djcelery 的任何管理命令时出现错误

D:\test\testapp>python manage.py celeryd -l info C:\Python27\lib\site-packages\django_celery-3.0.4-py2.7.egg\djcelery\loaders.py:116:
UserWarning: Using settings .DEBUG 导致内存泄漏，n warnings.warn("Using settings.DEBUG 导致内存泄漏，never "

提前致谢

我正在尝试使用kombu编写一个同时处理两条消息的服务器。我的交通工具是rabbitmq。

我相信答案是使用 kombu 和 pika-async。但是，似乎没有任何关于如何执行此操作的文档。

帮助？