代码拉取完成,页面将自动刷新
同步操作将从 rzxxysy/stock 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
# -*-coding=utf-8-*-
import datetime
import re
__author__ = 'Rocky'
'''
http://30daydo.com
Contact: weigesysu@qq.com
'''
from settings import get_engine,get_mysql_conn
import pandas as pd
def clone_database():
local_db =get_mysql_conn('db_zdt',local=True)
cur = local_db.cursor()
cur.execute('show tables')
tables=cur.fetchall()
local_engine = get_engine('db_zdt',local=True)
dfs=[]
for table in tables:
try:
result =re.findall('(\d+)zdt$', table[0])
if result:
print(table[0])
current = result[0]
# d= datetime.datetime.strptime(current,'%Y%m%d').strftime('%Y-%m-%d')
# print(d)
df =pd.read_sql(table[0],local_engine,index_col='index')
# df['涨停日期']=d
df=df.rename(columns={'最后一次涨停时间A':'最后一次涨停时间','第一次涨停时间A':'第一次涨停时间'})
try:
print(df.head())
df.to_sql(table[0],local_engine,if_exists='replace')
except Exception as e:
print(e)
except Exception as e:
print(e)
print(table[0])
# dfs.append(pd.read_sql(table[0],local_engine))
# df= pd.concat(dfs)
# print(df.head())
def merge_database():
local_db =get_mysql_conn('db_zdt',local=True)
cur = local_db.cursor()
cur.execute('show tables')
tables=cur.fetchall()
local_engine = get_engine('db_zdt',local=True)
dfs=[]
for table in tables:
try:
result =re.findall('(\d+)zdt$', table[0])
if len(result)>0:
print(table[0])
df =pd.read_sql(table[0],local_engine,index_col='index')
dfs.append(df)
except Exception as e:
print(e)
print(table[0])
dfx= pd.concat(dfs)
print(dfx.head())
# ali_engine = get_engine(None,local=False)
local_engine_stock=get_engine('db_stock',local=True)
dfx.to_sql('tb_zdt',local_engine_stock,if_exists='replace')
if __name__=="__main__":
# clone_database()
merge_database()
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。