小李：嘿，小王，最近我在研究数据中台，听说呼和浩特那边也在推进相关项目？
小王：是啊，呼和浩特的数据源比较丰富，比如政务、交通、环保这些领域的数据都集中在一起。数据中台正好可以整合这些资源。
小李：那你们是怎么做的？有没有具体的代码示例？
小王：有的。我们用Python写了一个简单的数据采集脚本，从本地的CSV文件中读取数据，并将其存入Hive表中。例如：
import pandas as pd
from pyhive import hive
# 读取CSV数据
df = pd.read_csv('data_source.csv')
# 连接Hive
conn = hive.Connection(host='localhost', port=10000, username='hive')
cursor = conn.cursor()
# 创建表（假设已存在）
cursor.execute("INSERT INTO TABLE data_center VALUES (1, 'example', '2025-04-05')")
# 插入数据
for index, row in df.iterrows():
cursor.execute(f"INSERT INTO TABLE data_center VALUES ({row['id']}, '{row['name']}', '{row['date']}')")
小李：这个例子不错！那数据中台如何处理多源异构的数据呢？
小王：我们会使用ETL工具如Apache Nifi或者Kettle来清洗和转换数据，确保不同来源的数据格式统一，再通过数据中台进行统一管理与服务化。
小李：明白了，看来数据中台在呼和浩特这样的城市确实能发挥很大作用。
小王：没错，尤其是在推动智慧城市建设方面，数据中台是关键基础设施。