zoukankan      html  css  js  c++  java
  • 删除一个存在的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()   #关闭连接
  • 相关阅读:
    kafka 学习笔记
    awk命令详解
    apache 的 配置项
    Apache 的 httpd.conf 详解
    如何设置httpd-mpm-conf的参数
    apache 服务器概述--安装(一)
    centos 修改时区
    docker(三)docker镜像和镜像发布方法
    docker(二)部署docker容器虚拟化平台
    sql的存储过程使用详解--基本语法
  • 原文地址:https://www.cnblogs.com/littlehb/p/9275521.html
Copyright © 2011-2022 走看看