Tushareネットワークは株式リストデータとmysqlを取得した後のデータ処理方式が異なる
2280 ワード
python, ,
, , ,
import time
import pandas as pd
import datetime
from sqlalchemy import create_engine
from mysql_tables_structure import Base
import pymysql
pymysql.install_as_MySQLdb()
#
#
engine = create_engine("mysql://root: @127.0.0.1/ ?charset=utf8MB4")
conn = engine.connect()
# mysql
Base.metadata.create_all(engine)
#
codes =pd.read_sql('select * from ', engine)
#
for EachID,index in zip(codes['ts_code'],codes.index):
print(EachID)
print(codes.loc[index][2]) #name
......
# Tushare
# tushare
ts.set_token(' token')
pro = ts.pro_api()
codes = get_stock_basic(pro, retry_count=3, pause=2)
for EachID,index in zip(codes['ts_code'],codes.index):
for EachID, name in zip(codes[0]['ts_code'], codes[0]['name']):
print(EachID)
print(name)
def get_stock_basic(pro, retry_count=3, pause=2):
""" """
frame = []
exc = ["SSE","SZSE"]
for ex in exc:
for status in ['L', 'D', 'P']:
for _ in range(retry_count):
try:
df = pro.stock_basic(exchange=ex, list_status=status,
fields='ts_code,symbol,name,area,industry,fullname,enname,market, \
exchange,curr_type,list_status,list_date,delist_date,is_hs')
except:
time.sleep(pause)
else:
frame.append(df)
# break
return frame