Python中如何将Wind终端的数据导入本地数据库？

核心方案：使用WindPy API获取数据，再用SQLAlchemy或pymysql写入数据库。

这里以MySQL为例，给出完整代码。你需要先安装依赖：pip install WindPy sqlalchemy pymysql。

import pandas as pd
from sqlalchemy import create_engine
import WindPy as wp

# 1. 初始化WindPy
wp.w.start()

# 2. 从Wind获取数据（示例：获取沪深300成分股行情）
data = wp.w.wsd(
    "000300.SH",  # 标的代码
    "open,high,low,close,volume",  # 指标
    "2024-01-01",  # 开始日期
    "2024-01-10",  # 结束日期
    ""
)

# 3. 转换为DataFrame
df = pd.DataFrame(data.Data, index=data.Fields, columns=data.Times).T
df.index.name = 'date'
df.reset_index(inplace=True)

# 4. 写入MySQL数据库
engine = create_engine('mysql+pymysql://user:password@localhost:3306/db_name')
df.to_sql('wind_data', con=engine, if_exists='append', index=False)

# 5. 关闭Wind连接
wp.w.close()

关键点说明：

• wp.w.wsd()是Wind通用数据接口，可换用w.wss()（截面数据）或w.wsi()（日内数据）。
• 数据库连接字符串格式：mysql+pymysql://用户名:密码@主机:端口/数据库名。
• to_sql()的if_exists参数可选'fail'（存在表则失败）、'replace'（覆盖）、'append'（追加）。

一句话建议：封装成函数，加入异常处理和日志记录会更稳健。