關於openstack中隊列池容量限制報錯的解決

在server.log中報出以下錯誤: python











顯示爲隊列池容量問題,致使鏈接失敗。 server

利用命令rabbitmqctl list_queues 查看隊列信息,發現q_plugin隊列中有150000條信息,別的隊列都是空的,顯然出問題了,應該是消息只進不出,緣由在於消息隊列堵塞,到底什麼緣由致使堵塞,不明確。 rabbitmq

解決辦法:寫一個python腳本,把q_plugin隊列中的全部消息取出,清空。 隊列

腳本代碼: 消息隊列



   import pika
   connection=pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
   channel=connection.channel()
   channel.queue_declare(queue='q-plugin')
   def callback(ch,method,properties,body):
           print "Received %r" % (body,)
   channel.basic_consume(callback,queue='q-plugin',no_ack=True)
   channel.start_consuming() it

說明:須要安裝pika包
io

相關文章
相關標籤/搜索