Python 推送RabbitMQ

Posted 2022-01-26 xuchunlin

username = ‘xxxxxxxx‘
pwd = ‘xxxxxxxx‘
user_pwd = pika.PlainCredentials(username, pwd)
s_conn = pika.BlockingConnection(pika.ConnectionParameters(‘110.318.111.211‘, credentials=user_pwd))
chan = s_conn.channel()
queuename = "pre_weibo_test"
exchange = "pre_weibo_test_exchange"
routkey = "pre_weibo_test"
chan.exchange_declare(exchange,"topic")
chan.queue_declare(queue=queuename)
chan.queue_bind(queue=queuename, exchange=exchange, routing_key=routkey)
chan.basic_publish(exchange=exchange,routing_key=routkey,body=‘ json data1‘)
s_conn.close()