renyupeng 3 éve
szülő
commit
be13002f30

+ 1 - 0
Apietl/kwai_etl/report/AccountDailyReport.py

@@ -210,6 +210,7 @@ class AccountDailyReport:
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)

+ 1 - 0
Apietl/kwai_etl/report/AccountHourlyReport.py

@@ -211,6 +211,7 @@ class AccountHourlyReport:
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)

+ 2 - 0
Apietl/kwai_etl/report/AccountReport.py

@@ -198,6 +198,7 @@ class AccountReport:
             print(sql)
             print(sql)
             TidbConn.upsert(conn=self.conn, sql_buff=sql)
             TidbConn.upsert(conn=self.conn, sql_buff=sql)
             self.conn.commit()
             self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
         except Exception as e:
         except Exception as e:
             logging.error('失败详细信息:', repr(e))
             logging.error('失败详细信息:', repr(e))
 
 
@@ -385,6 +386,7 @@ class AccountReport:
             print(sql)
             print(sql)
             TidbConn.upsert(conn=self.conn, sql_buff=sql)
             TidbConn.upsert(conn=self.conn, sql_buff=sql)
             self.conn.commit()
             self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
         except Exception as e:
         except Exception as e:
             logging.error('失败详细信息:', repr(e))
             logging.error('失败详细信息:', repr(e))
 
 

+ 1 - 0
Apietl/kwai_etl/report/CampaignHourlyReport.py

@@ -211,6 +211,7 @@ class CampaignHourlyReport:
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)

+ 1 - 0
Apietl/kwai_etl/report/MateirialVideoDailyReport.py

@@ -291,6 +291,7 @@ from media_api.kuaishou_material_video_report_daily report
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)

+ 1 - 0
Apietl/kwai_etl/report/MateirialVideoHourlyReport.py

@@ -292,6 +292,7 @@ from media_api.kuaishou_material_video_report_hourly report
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)

+ 1 - 0
Apietl/kwai_etl/report/UnitDailyReport.py

@@ -214,6 +214,7 @@ class UnitDailyReport:
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)

+ 1 - 0
Apietl/kwai_etl/report/UnitHourlyReport.py

@@ -216,6 +216,7 @@ class UnitHourlyReport:
                 print(sql)
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
                 self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
             return 0
             return 0
         except Exception as e:
         except Exception as e:
             logging.error(e)
             logging.error(e)