rabbitmq相关内容
我可以设置一个与Django Celery一起使用的不同数据库吗?我有一个项目配置有多个数据库,不希望Django Celery使用默认值。 如果我仍然可以使用django芹菜管理页面并读取存储在这个不同数据库中的结果,我将会很好:) 解决方案 应该可以使用Django数据库路由器为django-celery模型设置一个单独的数据库: https:// docs。 django
..
从任务导入t1 ,t2,t3 从芹菜进口链 res = chain(t1.s(123)| t2.s()| t3.s())() res.get() 我如何将其他任务附加到这个特定的链? p> res.append(t2.s()) 我的目标是确保链条按照我在代码中指定的顺序执行。 如果一个任务在我的链中失败,以下任务不会执行。 知道我在指
..
所以我有一个Django应用程序偶尔会向Celery发送一个任务来进行异步执行。我发现,当我开发我的代码时,Django开发服务器知道如何自动检测代码是否已更改,然后重新启动服务器,以便我可以看到我的更改。然而,我的应用程序的RabbitMQ / Celery部分并没有接受这些发展变化。如果我更改以后在Celery任务中运行的代码,Celery仍然会继续运行旧版本的代码。唯一的办法就是取得这个变化
..
我最近接管了我公司正在开展的项目的另一部分,并发现了我们的RabbitMQ / Celery设置中似乎是内存泄漏。 我们的系统有2Gb的内存,在任何给定的时间大约有1.8Gb的空闲。我们有多个任务可以收集大量的数据并将其添加到我们的数据库中。 当这些任务运行时,它们消耗了相当大量的内存,迅速萎缩了我们可用的记忆到16Mb到300Mb之间的任何地方。问题是,这些任务完成后,内存不会回来。
..
我正在尝试用django和rabbit-mq设置celeryd。到目前为止,我已经完成了以下工作: 从pip安装芹菜 已安装rabbitmq 通过rabbitmqctl向rabbitmq添加用户和vhost,以及该用户的权限 启动了rabbitmq-server 通过pip安装django-celery 设置django-celery,包括其表 settings.py(BROKE
..
我最近从2.3.0升级到Celery 3.0.1,所有的任务运行正常。不幸。我经常遇到“框架错误”异常。我也运行主管重新启动线程,但由于这些从来没有真正的杀死主管无法知道芹菜需要重新启动。有没有人看过这个? 2012-07-13 18:53:59,004:错误/ MainProcess]不可恢复的错误:异常'框架错误,收到0x00而期望0xce') 追溯(最近的最后一次调用): 文件“/u
..
我试图让RabbitMQ与Celery和Django进行EC2实例做一些相当基本的后台处理。我在一个大的EC2实例上运行rabbitmq-server 2.5.0。 我根据说明书下载并安装了测试客户端这里(在页面底部)。我只是让测试脚本走了,并得到预期的输出: recving rate:2350 msg / s,min /平均/最大延迟:588078478/588352905/588
..
我正在使用RabbitMQ与Django通过芹菜。我使用最基本的设置: #RabbitMQ连接设置 BROKER_HOST ='localhost' BROKER_PORT ='5672' BROKER_USER ='guest' BROKER_PASSWORD ='guest' BROKER_VHOST ='/' 我导入了一个芹菜任务,排队等待一年后运行。从iPy
..
当我们在Python中有一个更强大的网络框架,称为Twisted,为什么我们需要RabbitMQ。我想了解有人想要使用RabbitMQ的原因。 请问您可以使用RabbitMQ提供场景或示例吗? 另外,在哪里可以找到教程关于如何使用RabbitMQ? 解决方案 让我告诉你一些使用MOM(面向消息的中间件)可能是最好的原因 去耦: 它可以解耦/分离应用程序的核心组件。没
..
我一直在打Django / Celery文档一段时间,需要一些帮助。 我希望能够使用django-celery运行定期任务。我已经看到互联网(和文档)的几种不同的格式和模式,应该如何使用Celery实现这一点... 有人可以帮助一个基本一个django-celery定期任务的创建,注册和执行的功能实例?特别是,我想知道我是否应该编写一个扩展PeriodicTask类并注册的任务,或者是
..
我有点困惑,我应该使用哪一个。我认为两者都会奏效,但是比其他人更好还是更适合? http://github.com/ask/carrot/tree/master http://github.com/ask/celery/tree/master 解决方案 如果您需要向AMQP消息队列发送/接收消息,请使用 carrot 。 如果要在多台计算机上运行计划任务,请使用 cele
..
UDATE3:发现问题。请看下面的答案。 更新2:似乎我可能通过运行djcelery教程来处理自动命名和相对导入问题manage.py shell,请参见下文。它仍然不适用于我,但现在我收到新的日志错误消息。 更新:我将日志添加到帖子的底部。似乎示例任务没有注册? 原始帖子 我我试图让django-celery开始运行。我没有能够通过这个例子。 我成功安装了rabbi
..
我已经设法通过对PeriodicTask进行子类化来定期在django-celery中工作。我试图创建一个测试任务,并设置它运行无用的东西。有用。 现在我无法阻止。我已经阅读了文档,我无法找到如何从执行队列中删除任务。我尝试使用celeryctl和使用shell,但是registry.tasks()是空的,所以我看不到如何删除它。 我已经看到建议我应该“撤销”它,但对于这一点,我似乎需
..
我们公司有一个基于Python的网站和一些基于Python的工作者节点,通过Django / Celery和RabbitMQ进行通信。我有一个基于Java的应用程序,它需要向Celery的工作人员提交任务。我可以从Java发送工作到RabbitMQ,但是Celery的工作人员从来没有收到工作。从查看两种类型的作业提交的数据包捕获,有差异,但我不能理解如何解释它们,因为很多是二进制的,我找不到有关解
..
我想建立 RabbitMQ PHP封装和 AMPQ PHP wrapper 在Windows(64)上使用Cygwin。 我已经成功构建了底层的C库(librabbitmq.dll),但我被困在'phpize'步骤: phpize &&& ./configure --with-rabbit&&&制作&& sudo make install 如果我理解正确,windows上没有'php
..
我有curl命令: curl -i -u guest:guest -H“content-type:application / json “ -XPUT \ http:// localhost:15672 / api / traces /%2f / my-trace \ -d'{”format“:”text“,”pattern“:” #“}' 我想在Java API中创
..
我使用rabbitMQ和grails,今天早上出现了问题。当我运行rabbitmqctl status它告诉我: C:\Users\BuildnTest2> rabbitmqctl status 节点'rabbit @ BUILDNTEST2-PC'... 错误:无法连接到节点'rabbit @ BUILDNTEST2-PC':nodedown诊断: - 节点及其端口在BUILDN
..
尝试创建一个新的连接到运行在不同的服务器上的rabbitmq时,我得到以下错误: java。 io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
..
我们正在开发一个实时应用程序,我们正在为websockets部分使用nginx推流模块。首先,数据从客户端发送到一个php脚本,它执行一些认证,并在数据库中存储所需的信息,然后将信息推送到nginx,然后将其发送到特定套接字上的订阅用户。通常情况下,会有更多的30个http请求从这个脚本到本地nginx(,我不确定是一件坏事吗?)。 问题 是否可以从php向nginx发送信息而不需要h
..
我有一个nodejs客户端,使用bramqp连接到RabbitMQ服务器。我的客户端可以连接到localhost中的Rabbit MQ服务器,并且运行良好。但是它无法连接到其他机器上的远程RabbitMQ服务器。我在远程服务器上打开了端口5672,所以我认为问题是在配置rabbitMQ服务器。如何解决这个问题? 解决方案 问题似乎是新的 rabbitmq访问控制政策 请阅读这篇文章:
..