titan data:

解决:
2006, "MySQL server has gone away (BrokenPipeError(32, \'Broken pipe\'))")',)
错误

titan_cloud/titan-data-sync/titan_data_function.py

@@ -29,13 +29,13 @@ class Data:
     def __init__(self, token):
     def __init__(self, token):
         # 创建请求数据线程
         # 创建请求数据线程
         self.token = token
         self.token = token
-        self.engine = create_engine(settings.DB_CONN_URL, encoding='utf-8', echo=False)
 
 
     # delete数据并且append
     # delete数据并且append
     def delete_append(self, data, table_name, info):
     def delete_append(self, data, table_name, info):
         """删除mysql表所有数据，to_sql追加新数据"""
         """删除mysql表所有数据，to_sql追加新数据"""
+        engine = create_engine(settings.DB_CONN_URL, encoding='utf-8', echo=False)
         try:
         try:
-            with self.engine.begin() as conn:
+            with engine.begin() as conn:
                 conn.execute('DELETE FROM ' + table_name)
                 conn.execute('DELETE FROM ' + table_name)
                 # rollback sql
                 # rollback sql
                 data.to_sql(table_name, conn, if_exists='append', index=False)
                 data.to_sql(table_name, conn, if_exists='append', index=False)
@@ -43,13 +43,17 @@ class Data:
         except Exception as ee:
         except Exception as ee:
             logging.error('delete_append failed: '+info, ee)
             logging.error('delete_append failed: '+info, ee)
             self.sendMail('delete_append failed: '+info, ee.args)
             self.sendMail('delete_append failed: '+info, ee.args)
-            self.error_log(table_name, self.engine, info, ee.args)
+            self.error_log(table_name, engine, info, ee.args)
+        finally:
+            """销毁对象"""
+            engine.dispose()
 
 
     # keep数据并且append
     # keep数据并且append
     def keep_append(self, data, table_name, info):
     def keep_append(self, data, table_name, info):
         """保留mysql表所有数据，to_sql追加新数据"""
         """保留mysql表所有数据，to_sql追加新数据"""
+        engine = create_engine(settings.DB_CONN_URL, encoding='utf-8', echo=False)
         try:
         try:
-            with self.engine.begin() as conn:
+            with engine.begin() as conn:
                 # rollback sql
                 # rollback sql
                 data.to_sql(table_name, conn, if_exists='append', index=False)
                 data.to_sql(table_name, conn, if_exists='append', index=False)
                 self.update_log(table_name, conn, info)
                 self.update_log(table_name, conn, info)
@@ -57,6 +61,9 @@ class Data:
             logging.error('keep_append failed: '+info, ee)
             logging.error('keep_append failed: '+info, ee)
             self.sendMail('delete_append failed: ' + info, ee.args)
             self.sendMail('delete_append failed: ' + info, ee.args)
             self.error_log(table_name, self.engine, info, ee.args)
             self.error_log(table_name, self.engine, info, ee.args)
+        finally:
+            """销毁对象"""
+            engine.dispose()
 
 
     # 同步更新日志表
     # 同步更新日志表
     def update_log(self, table_name, conn, info):
     def update_log(self, table_name, conn, info):