renyupeng 3 years ago
parent
commit
22836d7cda
1 changed files with 1 additions and 1 deletions
  1. 1 1
      Apietl/kwai_etl/report/CampaignDailyReport.py

+ 1 - 1
Apietl/kwai_etl/report/CampaignDailyReport.py

@@ -210,7 +210,7 @@ class CampaignDailyReport:
         where report.stat_date between {start_time} and {end_time} order by campaign_id,stat_date limit {num},20000""". \
                     format(start_time=self.start_time, end_time=self.end_time, num=i * 20000)
                 print(sql)
-                TidbConn.exec_sql(self.conn, sql)
+                TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()
             return 0
         except Exception as e: