使用100％CPU的RabbitMQ python工作者脚本

我通过修改RabbitMQ教程中的默认RPC示例找到here，将此python脚本用作RPC服务器。它在我的笔记本上运行良好。但是，当我在Amazon EC2的高CPU中等实例与这些规格运行：使用100％CPU的RabbitMQ python工作者脚本

1.7的存储器吉布

5个EC2计算单元（2个虚拟核用2.5每个EC2计算单元）

350 GB的实例存储

它占用了100％的CPU。虽然我的笔记本电脑几乎具有相同的配置，但CPU使用率不到4％。我在我的笔记本电脑和亚马逊的Ubuntu-12.04上运行此操作系统。

这里是我的代码

#!/usr/bin/env python 
    import pika 
    import commands 
    import socket 
    import base64 

    connection = pika.BlockingConnection(pika.ConnectionParameters(
      host='localhost')) 
    channel = connection.channel() 
    channel.queue_declare(queue='rpc_queue') 
    def on_request(ch, method, props, body): 
     #print body 
     body = base64.b64decode(body) 
     print body 
     run = commands.getoutput(body) 
     response = socket.gethostname() 
     print response 
     ch.basic_publish(exchange='', 
         routing_key=props.reply_to, 
         properties=pika.BasicProperties(correlation_id = \ 
                 props.correlation_id), 
         body=str(response)) 
     ch.basic_ack(delivery_tag = method.delivery_tag) 
    channel.basic_qos(prefetch_count=1) 
    channel.basic_consume(on_request, queue='rpc_queue') 
    print " [x] Awaiting RPC requests" 
    channel.start_consuming()

我怎样才能解决这个问题？

来源

2013-02-14 Manu

终于找到了问题。这是Pika中的一个bug，我从rabbitmq的邮件列表中获得了这些信息。我通过pypi安装了pika。 pip install pika。

为了解决这个问题我卸载鼠

pip uninstall pika

和混帐

pip install git+https://github.com/pika/pika.git重新安装它。

而且解决了它。

来源

2013-02-15 06:38:47 Manu

如果您可以提供问题链接，那将会很棒。我知道，它很长时间。但它有很大帮助！ – 2016-04-29 07:24:36

@HariKrishnan这是错误https://github.com/pika/pika/issues/361 – 2017-11-16 17:08:52

使用100％CPU的RabbitMQ python工作者脚本

回答

相关问题