#!/usr/bin/python
import tushare as ts
import os
import re
from sqlalchemy import create_engine
import cx_Oracle
p_ktype='W'
sql="select stockcode from stock_temp order by stockcode "
engine = create_engine('oracle+cx_oracle://stock:stock@192.168.1.10/orcl')
cnx = engine.connect()
index = 0
for stock in cnx.execute(sql):
stocknum = stock[index]
if stocknum != "":
df = ts.get_hist_data(code=stocknum[2:8])
df.index.names=['op_time']
df['STOCKID']= stocknum
df['ktype']= p_ktype
df.to_csv('/root/stock_py/data/data_stock/'+stocknum+'.txt')
# df.to_sql('iq_stock',cnx,if_exists='append',chunksize=500)
index +=1
cnx.close()
转载请注明原文地址: https://ju.6miu.com/read-914.html
