浏览代码

pq mysql 增加 connection
的超时时间以及重试次数,
后续在下游 初始化 pq mysql 的时候会增加数据库连接失败的报警

luojunhui 6 月之前
父节点
当前提交
d42c8ce4a0
共有 1 个文件被更改,包括 9 次插入1 次删除
  1. 9 1
      applications/pqMysql.py

+ 9 - 1
applications/pqMysql.py

@@ -10,8 +10,16 @@ class PQMySQL(object):
     PQ Mysql
     PQ Mysql
     """
     """
 
 
-    @retryOnTimeout()
     def __init__(self):
     def __init__(self):
+        self.connection = None
+        self.connect_to_db()
+
+    @retryOnTimeout()
+    def connect_to_db(self):
+        """
+        连接 数据库
+        :return:
+        """
         self.connection = pymysql.connect(
         self.connection = pymysql.connect(
             host='rm-bp1159bu17li9hi94.mysql.rds.aliyuncs.com',
             host='rm-bp1159bu17li9hi94.mysql.rds.aliyuncs.com',
             port=3306,
             port=3306,