如何将报文从rabbitMQ发送到物联网集线器设备？

import pika

# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明要发送的队列
channel.queue_declare(queue='iot_queue')

# 发送报文到队列
channel.basic_publish(exchange='', routing_key='iot_queue', body='Hello IoT!')

# 关闭连接
connection.close()

import pika

# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明要接收的队列
channel.queue_declare(queue='iot_queue')

# 定义接收报文的回调函数
def callback(ch, method, properties, body):
    print("Received message: %r" % body)

# 监听队列并接收报文
channel.basic_consume(queue='iot_queue', on_message_callback=callback, auto_ack=True)

# 开始接收报文
channel.start_consuming()