kombu

3热度

1回答

架构考虑一个带有DB记录的系统。每条记录可以是live或expired状态;应使用外部软件模块定期处理live记录。我已经用Kombu和RabbitMQ的经典生产者 - 消费者体系结构解决了这个问题。生产者每隔几秒从DB获取记录，并由消费者处理它们。问题的live事件的数量差别很大，并在高峰时段，消费者不能处理负载和队列堵塞物品万人。我想使系统具有适应性，以便生产者在队列为空时不会向消费

1热度

1回答

海带 - 类型错误：结构（）参数1必须是字符串，而不是UNICODE

我一直在使用Kombu了一段时间了 - 而今天，当我准备好一台新机器进行部署，我就import得到TypeError从kombu： >>> import kombu >>> from kombu import Connection, Exchange, Queue, Producer Traceback (most recent call last): File "<stdin>",

-1热度

2回答

获取导入错误：无法导入名称OrderedDict

我收到错误 ImportError: cannot import name OrderedDict ，而我的Ubuntu 14.04机器上安装本地的服务器。我曾尝试手动安装ordereddict也试图提升海带但它仍然给如下─ [email protected]:~/open-event-orga-server$ sudo python create_db.py Traceback (most r

0热度

1回答

ImportError：无法导入名称OrderedDict;降级kombu

我想安装并导入pytplot，这是一个可以使用python绘制IDL保存文件的包。我在Windows 10上安装了Python 2.7。如果我尝试导入pytplot，我得到一个导入错误：ImportError：无法导入名称OrderedDict。这个问题已经在这里回答了：Getting ImportError: cannot import name OrderedDict。但是，我无法弄清楚如何

0热度

1回答

无法从Python连接到RabbitMQ

我正在学习Python，并遇到奇怪的问题。我在我的macOS Sierra本地盒子上运行RabitMQ。从python脚本连接到RabbitMQ服务器总是失败，并发生套接字超时错误。同时我可以通过telnet连接。运行的Python 2.7和库海带： # test.py from kombu import Connection connection = Connection('amqp:/

3热度

1回答

气流运行从UI，KeyError异常任务：没有这样的运输

与芹菜气流CFG设置为： broker_url = 'amqp://guest:[email protected]_server:8080' celery_result_backend = db+postgresql://developer:[email protected]_server:5432/db_name 的airflow webserver运行正常，但在运行从气流UI任务我得到

0热度

1回答

如何正确使用内存中的传输进行单元测试

我想写一些测试，其中我产生一个消息到一个队列，看看消息是否得到正确使用和应用程序处理。为此，我正在玩kombu库，特别是内存中的Transport实现。仍然我无法得到它的工作，生产的消息被消耗。因此我的问题是，如果有人能提供生产和内存消耗的消息简单的单元测试

3热度

1回答

在pytest中模拟一个连接类

我有一个继承kombu.ConsumerProducerMixin的类，我希望在没有运行实际的rabbitmq服务的情况下进行测试。 class Aggregator(ConsumerProducerMixin): def __init__(self, broker_url): exchange_name = 'chargers' self.status = 0

0热度

1回答

从kombu安装（u'json'，）没有编码器

我想我错过了某个步骤，但我一直在找，并找不到它。当我运行我的芹菜任务时，当我拨打get_task.delay(args)时，我得到此错误消息no encoder installed for (u'json',)。我想我有自己的自定义序列化？ settings.py CELERY_ACCEPT_CONTENT = ['pickle'] CELERY_TASK_SERIALIZER = 'json'

0热度

1回答

Heroku：dbm.error：db类型是dbm.gnu，但该模块不可用

如何修复下面的错误？看起来它必须由Heroku安装。我是否必须发送电子邮件到heroku进行安装？或者没有办法做到这一点？ 2017-03-26T13:04:08.185159+00:00 heroku[beat.1]: Starting process with command `celery -A PROJECT beat -l info` 2017-03-26T13:04:08.85543