python - 使用100％CPU的RabbitMQ python worker脚本

通过修改RabbitMQ教程here中的默认RPC示例，我将此Python脚本用作RPC服务器。在我的笔记本电脑上运行正常。但是当我在具有这些规范的亚马逊ec2 High CPU Medium Instance中运行它时:



它占用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()

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

最佳答案

终于找到了问题所在。这是皮卡(Pika)中的错误，我从Rabbitmq的邮件列表中获得了此信息。我已经通过pypi安装了pika。 pip install pika。

为了解决这个问题，我卸载了pika
pip uninstall pika
并从git重新安装
pip install git+https://github.com/pika/pika.git。

这就解决了。

关于python - 使用100％CPU的RabbitMQ python worker脚本，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/14870832/