python的学习之路===小白学编程

Posted 2021-01-21 獒游天堂

额不找接口，就是懈怠了。。。。

数据库表弄好了，但是返回来写又出问题了。。检查了半点才发现是拼写错误。。。。

混乱的思路一直没有理清，所以建好的表结构发现也还是不能够马上用。。。。。。。。。。。。

似乎方法出问题了。

下面换个思路吧：每个练习学习的文件明确一个目标，不把所有的都放进来，这样也比较好分离错误。

更新基础信息表,通过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语句。