6

我编写了这个 python 脚本，它通过修改此处找到的 RabbitMQ 教程中的默认 RPC 示例来充当 RPC 服务器。它在我的笔记本电脑上运行良好。但是当我在具有这些规格的亚马逊 ec2 高 CPU 中型实例中运行它时：

1.7 GiB 内存

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()

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

4

1 回答 1

6

终于发现问题了。这是 Pika 中的一个错误，我从 rabbitmq 的邮件列表中获得了这些信息。我已经通过 pypi 安装了 pika。pip install pika.

为了解决这个问题，我卸载了 pika

pip uninstall pika

并从 git 重新安装

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

这解决了它。

于 2013-02-15T06:38:47.190 回答