类似的问题似乎都是基于使用自定义记录器,我很高兴只使用默认的/none。我的pika python应用程序运行并接收消息,但是在几秒钟后,由于No handlers could be found for logger "pika.adapters.blocking_connection"
崩溃,有什么想法吗?
import pika
credentials = pika.PlainCredentials('xxx_apphb.com', 'xxx')
parameters = pika.ConnectionParameters('bunny.cloudamqp.com', 5672, 'xxx_apphb.com', credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.queue_declare('messages')
def message_received(channel, method, properties, body):
print "[x] Received %r" % (body)
channel.basic_consume(message_received, queue='messages', no_ack=True)
channel.start_consuming()
通过添加修复:
import logging
logging.basicConfig()
通过添加修复:
应提供exchange名称,不应保留默认值。
相关问题 更多 >
编程相关推荐