python的学习之路===小白学编程(3)

it2022-05-05  115

。。不找借口,就是懈怠了。。。。 数据库表弄好了,但是返回来写又出问题了。。检查了半点才发现是拼写错误。。。。 混乱的思路一直没有理清,所以建好的表结构发现也还是不能够马上用。。。。。。。。。。。。 似乎方法出问题了。 下面换个思路吧:每个练习学习的文件明确一个目标,不把所有的都放进来,这样也比较好分离错误。 更新基础信息表,通过tushare.pro_api的的通用接口获得:   # coding:utf-8 import tushare as t from sqlalchemy import create_engine db_connect =create_engine('mysql+ pymysql://root:Z**********@localhost/9arses') #engine = create_engine('sqlite://', echo=False) # 下面尝试使用通用模板获取数据 api = t.pro_api('ccf4650d0fa9ca2691a4e44c2715a2658cb1d84356be983a6a8550a6') p = t.pro_api() sdata = p.query("stock_basic", fields='ts_code,symbol,name,area,industry,fullname,enname,market,exchange,curr_type,list_status,list_date,delist_date,is_hs' ) bsdata.to_csv('bsdata.csv', sep=',', header=True, index=True) bsdata.to_sql('c_gp_list', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) #清单 trade_cal = p.query("trade_cal",fields='exchange,cal_date,is_open,pretrade_date') trade_cal.to_csv('trade_cal.csv', sep=',', header=True, index=True) trade_cal.to_sql('c_gp_jy_date', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) #交易日历 stock_company = p.query("stock_company",fields='ts_code,exchange,chairman,manager,secretary,reg_capital,setup_date,province,city,introduction,website,email,office,employees,main_business,business_scope') stock_company.to_csv('stock_company.csv', sep=',', header=True, index=True) stock_company.to_sql('c_gp_info', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) #股票基本信息   hs_const = p.hs_const(hs_type='SH') hs_const.to_csv('hs_const.csv', sep=',', header=True, index=True) hs_const.to_sql('c_gp_type', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) p.hs_const(hs_type='SZ') hs_const.to_csv('hsz_const.csv', sep=',', header=True, index=True) hs_const.to_sql('c_gp_type', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) #沪股通成分股 namechange = p.query("namechange",fields='ts_code,name,start_date,end_date,ann_date,change_reason') namechange.to_csv('namechange.csv', sep=',', header=True, index=True) namechange.to_sql('c_gp_name_his', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) #股票曾用名 new_share = p.query("new_share",fields='ts_code,sub_code,name,ipo_date,issue_date,amount,market_amount,price,pe,limit_amount,funds,ballot') new_share.to_csv('new_share.csv', sep=',', header=True, index=True) new_share.to_sql('c_gp_ipo', db_connect,if_exists='append',index=True,index_label=None,dtype=None,chunksize=None) #IPO   对于这些基础信息数据,数据量不大,每次连接直接更新即可。 另外代码重复很多,可以考虑for语句完成。 主要有三个语句,第一个取数据,第二个写入csv文件(比较用,可省略),第三个写入数据库 第一个取数语句主要有两个参数 接口名称、字段列表,都是字符串格式的。 第三个写入sql的表名,其余基本一致。 那就是三个字符串为一组的数据。 研究一下,用哪种数据类型, 复习一下string、list、dict、truple、set 以及学习一下for语句。              

转载于:https://www.cnblogs.com/marses/p/9998760.html

相关资源:各显卡算力对照表!

最新回复(0)