删除一个存在的RabbitMQ队列


import sys

# pip install kafka-python
sys.path.append("/usr/local/software/ELK")
from Util.RabbitMqUtil import *
queue_Name = 'kafka_queue'
host = RabbitMq_IP
creds = pika.PlainCredentials(RabbitMq_User, RabbitMq_Password)
params = pika.ConnectionParameters(host=RabbitMq_IP,
                                                                       port=int(RabbitMq_Port),
                                                                       virtual_host='/',
                                                                       heartbeat_interval=0,
                                                                       socket_timeout=5,
                                                                       credentials=pika.PlainCredentials(
                                                                           RabbitMq_User, RabbitMq_Password))


connection = pika.BlockingConnection(params)
channel = connection.channel()
channel.queue_delete(queue=queue_Name)
connection.close()

 创建一个队列

import sys
# pip install kafka-python
sys.path.append("/usr/local/software/ELK")
from Util.RabbitMqUtil import *
queue_Name = 'kafka_queue'
host = RabbitMq_IP
creds = pika.PlainCredentials(RabbitMq_User, RabbitMq_Password)
params = pika.ConnectionParameters(host=RabbitMq_IP,
                                                                       port=int(RabbitMq_Port),
                                                                       virtual_host='/',
                                                                       heartbeat_interval=0,
                                                                       socket_timeout=5,
                                                                       credentials=pika.PlainCredentials(
                                                                           RabbitMq_User, RabbitMq_Password))

connection = pika.BlockingConnection(params)
channel = connection.channel()
channel.queue_declare(queue=queue_Name)    #声明队列以向其发送消息消息
#channel.basic_publish(exchange='', routing_key='test', body='Hello World!')  #注意当未定义exchange时,routing_key需和queue的值保持一致
#print('send success msg to rabbitmq')
connection.close()   #关闭连接

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM