码迷,mamicode.com
首页 > 数据库 > 详细

SqlAlchemy “Too many connections”

时间:2019-02-01 15:47:54      阅读:205      评论:0      收藏:0      [点我收藏+]

标签:api   nmake   nbsp   das   http   metadata   ges   pandas   exit   

 

 File "C:\Users\user\AppData\Local\Programs\Python\Python36\lib\site-packages\pymysql\connections.py", line 393, in check_error
    err.raise_mysql_exception(self._data)
  File "C:\Users\user\AppData\Local\Programs\Python\Python36\lib\site-packages\pymysql\err.py", line 107, in raise_mysql_exception
    raise errorclass(errno, errval)
sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (1040, Too many connections) (Background on this error at: http://sqlalche.me/e/e3q8)

Process finished with exit code 1

 

 

1、pandas dataframe to_sql()

#连接数据库
def getEngine():
    engine = create_engine(mysql://root:123456@127.0.0.1/databaseName?charset=utf8mb4,echo=False)
    #print(engine)
    return engine
def getSession():
    engine = getEngine()
    BaseMode.metadata.create_all(engine)
    Session = sessionmaker(bind=engine)
    session = Session()
    return session

 

def get_stock_daily(ts_code, start_date,end_date,startTime):
    # print( ts_code + "  " + str(start_date) + "  " + str(end_date))
    api = ts.pro_api(token)

    try:
        df = ts.pro_bar(pro_api=api, ts_code=ts_code, start_date=start_date, end_date=end_date)  # 【获取数据】
        if df is None:
            print("没有获取到数据")
            return None

        print("data count: " + str(len(df)))
        df[trade_date] = pd.to_datetime(df[trade_date])  # 交易日期字符串转换成日期格式

        conn = cheDbUtil.getEngine()
        try:
            df.to_sql(b_stock_daily, con=conn, if_exists=append, index=False)  # replace/append/fail 【save】
        except Exception as e:
            traceback.print_exc()
            print("get_stock_daily() in BaaBusiniessPro.py XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX")
            return None
        finally:
            conn.dispose()
    except Exception as e:
        sleepNeed = 60
        print("Start to sleep  " + str(sleepNeed) + )
        print("当前耗时: " + str(round((time.time() - startTime), 2) / 60) +  分钟)
        time.sleep(sleepNeed)  # 休眠 ? 秒

2、SqlAlchemy  操作 mysql

#获取日行情最后一条记录的日期
def getMaxTradeDateForStockDaily(ts_code):
    try:
        session = getSession()
        rows = session.query(func.max(StockDaily.trade_date)).filter(StockDaily.ts_code == ts_code).one()
        # print(str(len(rows)))
        # print(type(rows))
        # print(str(rows))
        if rows is not None and len(rows) == 1:
            return rows[0]
        return None
    except Exception as e:
        traceback.print_exc()
        print("getMaxTradeDateForStockDaily() XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX")
        return None
    finally:
        session.close()

 

SqlAlchemy “Too many connections”

标签:api   nmake   nbsp   das   http   metadata   ges   pandas   exit   

原文地址:https://www.cnblogs.com/quietwalk/p/10345798.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!