消息推送系统

                # 导入所需的库
                import pika
                
                # 连接到消息队列服务器
                connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
                channel = connection.channel()
                
                # 定义一个回调函数，用于处理接收到的消息
                def callback(ch, method, properties, body):
                    print(" [x] Received %r" % body)
                
                # 声明一个队列，用于接收来自航天器的状态更新
                channel.queue_declare(queue='spacecraft_status')
                
                # 设置回调函数
                channel.basic_consume(queue='spacecraft_status', on_message_callback=callback, auto_ack=True)
                
                # 开始消费消息
                print(' [*] Waiting for messages. To exit press CTRL+C')
                channel.start_consuming()