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