共计 739 个字符，预计需要花费 2 分钟才能阅读完成。
要消费 Kafka 数据并将其写入 数据库，可以按照以下步骤进行操作：
- 首先，确保已经安装了 kafka-python 库，可以使用以下命令安装：
pip install kafka-python- 导入所需的模块：
from kafka import KafkaConsumer
import json
import pymysql- 创建 KafkaConsumer 实例，指定要消费的 topic 和 Kafka服务器 地址：
consumer = KafkaConsumer('', bootstrap_servers='')- 创建一个 MySQL 数据库 连接：
conn = pymysql.connect(host='', port=, user='', password='', db='')
cursor = conn.cursor()- 使用循环遍历消费 Kafka 消息并将其写入数据库：
for message in consumer:
# 解析 JSON 格式的消息
data = json.loads(message.value)
# 提取所需的数据字段
field1 = data['field1']
field2 = data['field2']
# ...
# 构造插入数据库的 SQL 语句
sql = "INSERT INTO (field1, field2) VALUES (%s, %s)"
values = (field1, field2)
# 执行 SQL 语句
cursor.execute(sql, values)
conn.commit()
- 最后，记得关闭数据库连接和 KafkaConsumer 实例：
cursor.close()
conn.close()
consumer.close()
以上是一个简单的示例，根据实际情况可能需要根据需要进行一些调整，如处理消息的格式、解析更多字段等。
丸趣 TV 网 – 提供最优质的资源集合！
正文完
转载说明：除特殊说明外本站除技术相关以外文章皆由网络搜集发布，转载请注明出处。
评论（没有评论）
站内搜索
