当前位置: 首页 > news >正文

读取CSV数据并写入MySQL

import pandas as pd
#import tushare as ts
from sqlalchemy import create_engineimport baostock as bs
#### 登陆系统 ####
lg = bs.login()
# 显示登陆返回信息
print('login respond error_code:'+lg.error_code)
print('login respond  error_msg:'+lg.error_msg)
#### 获取沪深A股历史K线数据 ####
# 详细指标参数,参见“历史行情指标参数”章节;“分钟线”参数与“日线”参数不同。
# 分钟线指标:date,time,code,open,high,low,close,volume,amount,adjustflag
rs = bs.query_history_k_data_plus("sh.600000","date,code,open,high,low,close,preclose,volume,amount,adjustflag,turn,tradestatus,pctChg,isST",start_date='2017-07-01', end_date='2017-12-31',frequency="d", 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)
#### 打印结果集 ####
data_list = []
while (rs.error_code == '0') & rs.next():# 获取一条记录,将记录合并在一起data_list.append(rs.get_row_data())
result = pd.DataFrame(data_list, columns=rs.fields)#### 结果集输出到csv文件 ####
result.to_csv("D:\\history_A_stock_k_data.csv", index=False)
print(result)
#engine=create_engine('mysql+pymysql://root:1234@127.0.0.1/mysql?charset=utf8mb4')
engine=create_engine('mysql+pymysql://root:1234@127.0.0.1/mysql?charset=utf8')
#result.to_sql(name='sh600000',con=engine,schema='mysql',if_exists='append',index_label='date')
data = pd.read_csv('D:\\history_A_stock_k_data.csv')
data.to_sql('mysql', con=engine, if_exists='replace')
print('success to sql!')
engine.dispose()
http://www.lryc.cn/news/312810.html

相关文章:

  • centos7.4下升级最新的ssh
  • Java实现的双向链表示例
  • 生物电信号测量技术
  • 【开源】JAVA+Vue.js实现创意工坊双创管理系统
  • Python基于opencv的人脸识别上课签到考勤系统,附源码
  • 【HTML】HTML基础7.2(有序列表)
  • ucode usage使用方法
  • HCIA-HarmonyOS设备开发认证V2.0-习题
  • 【深度学习笔记】优化算法——随机梯度下降
  • oss-fuzz-gen:一款基于LLM的模糊测试对象生成与评估框架
  • 深度神经网络 基本知识 记录
  • 基于Springboot免费搭载轻量级阿里云OSS数据存储库(将本地文本、照片、视频、音频等上传云服务保存)
  • RK3568 Android12 适配抖音 各大APP
  • [渗透教程]-022-内网穿透的高性能的反向代理应用
  • 【计算机网络】深度学习HTTPS协议
  • C盘新建的文件夹内需要管理员权限才能新建和删除解决问题记录
  • 2024年【道路运输企业安全生产管理人员】考试报名及道路运输企业安全生产管理人员免费试题
  • 四面体单元悬臂梁的Matlab有限元编程 | 实体单元 | Matlab源码 | 理论文本
  • BurpSuite2024.2.1
  • 【投稿优惠|火热征稿】2024年计算机技术与自动化发展国际会议 (ICCTAD 2024)
  • LeetCode.232. 用栈实现队列
  • SpringBoot集成ElasticSearch(ES)
  • 基于STC12C5A60S2系列1T 8051单片机的TM1638键盘数码管模块的数码管显示应用
  • Qt插件之输入法插件的构建和使用(一)
  • 慢SQL调优-索引详解
  • 知乎语音下载(mediadown)
  • 2023 最新 IntelliJ IDEA 2023.3 详细配置步骤演示:新入职如何快速配置 IntelliJ IDEA?
  • Linux 下安装 Git
  • Manomotion 实现AR手势互动-解决手势无效的问题
  • 第十五届蓝桥杯第三期模拟赛(Java)