RabbitMQ Python工作脚本占用100% CPU

Question

我写了一个Python脚本，它通过修改RabbitMQ教程中的默认RPC示例，变成了一个RPC服务器。这个脚本在我的笔记本电脑上运行得很好。但是，当我在一个亚马逊EC2的高CPU中型实例上运行时，情况就不一样了。这个实例的配置是：

1.7 GiB的内存

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

350 GB的实例存储

在这个实例上，CPU使用率达到了100%。而我的笔记本电脑配置几乎相同，运行这个脚本时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()

我该如何解决这个问题呢？

Answer 1

最后我找到了问题所在。原来是Pika这个库里有个bug，我是在RabbitMQ的邮件列表上看到这个信息的。我是通过pypi安装的pika，命令是pip install pika。

为了修复这个问题，我先卸载了pika，命令是

pip uninstall pika

然后我从git上重新安装了一遍，命令是

pip install git+https://github.com/pika/pika.git。

这样就解决了问题。