python3.9发送RABBITMQ消息

import pika
import json

# 连接到RabbitMQ服务器
credentials = pika.PlainCredentials('admin', 'admin123')
connection = pika.BlockingConnection(pika.ConnectionParameters('172.30.12.32', 5672, '/', credentials))
channel = connection.channel()

# 绑定交换器和队列
channel.queue_bind(queue='MY_DIRECT_GOODS_QUEUE', exchange='my_direct_exchange')

# 转json格式
data = {'name': 'John Doe', 'age': 30}
message = json.dumps(data)

# 发送消息
channel.basic_publish(exchange='my_direct_exchange', body=message, routing_key='')