PYTHON写代码 在baostock库中,导出股票代码为SZ.002195的15分钟行情数据到MYSQL中 host='localhost', user='root', password='123456', database='STOCK_CODES'
时间: 2024-01-15 15:02:54 浏览: 70
以下是示例代码,需要安装baostock和pymysql库:
```python
import baostock as bs
import pymysql
# 连接数据库
db = pymysql.connect(host='localhost', user='root', password='123456', database='STOCK_CODES')
cursor = db.cursor()
# 登录baostock系统
lg = bs.login()
# 获取SZ.002195的15分钟行情数据
rs = bs.query_history_k_data_plus("sz.002195", "date,time,code,open,high,low,close,volume,amount", start_date='2020-01-01', end_date='2021-07-01', frequency='15', adjustflag='3')
print('query_history_k_data_plus respond error_code:'+rs.error_code)
print('query_history_k_data_plus respond error_msg:'+rs.error_msg)
# 循环遍历结果集,将数据插入到数据库中
while (rs.error_code == '0') & rs.next():
data = rs.get_row_data()
sql = "INSERT INTO stock_data (date, time, code, open, high, low, close, volume, amount) VALUES ('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s')" % (data[0], data[1], data[2], data[3], data[4], data[5], data[6], data[7], data[8])
try:
cursor.execute(sql)
db.commit()
except:
db.rollback()
# 登出系统
bs.logout()
# 关闭数据库连接
db.close()
```
以上代码中,我们使用了baostock库中的`query_history_k_data_plus`方法获取股票代码为SZ.002195的15分钟行情数据,并使用pymysql库将数据插入到MYSQL数据库中。在运行代码之前,请确保先创建了名为`STOCK_CODES`的数据库,并且在该数据库中创建了名为`stock_data`的数据表。
阅读全文