import pika
credentials = pika.PlainCredentials('xxxxxxxxxxxxxxxxx==',
'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx')
connection = pika.BlockingConnection(pika.ConnectionParameters(
'rabbitmq-serverless-cn-y1i3ptrzv06.cn-hangzhou.amqp-11.net.mq.amqp.aliyuncs.com', 5672, virtual_host='zhgj', credentials=credentials))
channel = connection.channel()
queue_name = "test"
channel.basic_publish(exchange='test',
routing_key='test',
body='Hello World!')
channel.queue_declare(queue='test',durable=True,passive=True)
print('Connected to RabbitMQ!')
connection.close()