表14-7 学生表student sno sname ssex sage 95001 John M 23 95002 Tom M 23 1. 根据上面给出的student表，编写Python程序完成如下操作： （1）读取student表的数据内容，将其转为JSON格式，发送给Kafka； （2）再从Kafka中获取到JSON格式数据，打印出来的需求分析

以下是使用Python将student表数据转换为JSON格式并发送到Kafka的代码：

import json
from kafka import KafkaProducer

# 读取student表的数据
data = [('95001', 'John', 'M', 23), ('95002', 'Tom', 'M', 23)]

# 将数据转换为JSON格式
json_data = json.dumps(data)

# 创建Kafka生产者，并发送JSON数据
producer = KafkaProducer(bootstrap_servers=['localhost:9092'])
producer.send('student_topic', json_data.encode('utf-8'))

以下是从Kafka中获取JSON格式数据并打印出来的代码：

import json
from kafka import KafkaConsumer

# 创建Kafka消费者，并订阅student_topic主题
consumer = KafkaConsumer('student_topic', bootstrap_servers=['localhost:9092'])

# 从Kafka中获取JSON格式数据并打印
for message in consumer:
    json_data = message.value.decode('utf-8')
    data = json.loads(json_data)
    print(data)

在上述代码中，我们从Kafka中获取到JSON格式数据后，将其转换为Python对象，并使用print语句打印出来。