我正在处理来自SQL server的数据,并在经过一些处理后将其写回。
处理过程需要花费一些时间(4-5小时),所以当我开始加载时,一个现有的连接被远程主机强行关闭了。
我想询问以下几点:
下面是我的流程示例:
#read
data = pd.read_sql_table(src, engine, schema=myschema)
#step 1
data = myfunc1(<args>)
#step 2
data = myfunc2(<args>)
#step 3
data = myfunc3(<args>)
#write
data.to_sql(tgt, engine, schema , index=False, if_exists="append")发布于 2017-07-14 09:08:20
试着利用断开处理-悲观
engine = create_engine(<your_connection_string>, pool_pre_ping=True)https://stackoverflow.com/questions/45098594
复制相似问题