python的學習之路===小白學程式設計(3)
阿新 • • 發佈:2018-11-22
額不找介面,就是懈怠了。。。。
資料庫表弄好了,但是返回來寫又出問題了。。檢查了半點才發現是拼寫錯誤。。。。
混亂的思路一直沒有理清,所以建好的表結構發現也還是不能夠馬上用。。。。。。。。。。。。
似乎方法出問題了。
下面換個思路吧:每個練習學習的檔案明確一個目標,不把所有的都放進來,這樣也比較好分離錯誤。
更新基礎資訊表,通過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語句。