renyupeng 3 anni fa
parent
commit
95bb34b0cd
1 ha cambiato i file con 2 aggiunte e 3 eliminazioni
  1. 2 3
      Apietl/kwai_etl/report/UnitDailyReport.py

+ 2 - 3
Apietl/kwai_etl/report/UnitDailyReport.py

@@ -27,7 +27,7 @@ class UnitDailyReport:
         try:
             sql = """
             select advertiser_id from media_api.kuaishou_unit_report_daily where 
-            stat_date between {start_time} and {end_time} group advertiser_id""".format(
+            stat_date between {start_time} and {end_time} group by advertiser_id""".format(
                 start_time=self.start_time, end_time=self.end_time)
             account_list = TidbConn.quary(sql)
             for account_id in account_list:
@@ -211,8 +211,7 @@ class UnitDailyReport:
              `jeecg-boot`.ctop_account_attribution_info sys
              on report.advertiser_id = sys.account_id
         where report.stat_date between {start_time} and {end_time}
-        and report.advertiser_id={account_id}""".\
-                    format(start_time=self.start_time, end_time=self.end_time, account_id=account_id[0])
+        and report.advertiser_id={account_id}""".format(start_time=self.start_time, end_time=self.end_time, account_id=account_id[0])
                 print(sql)
                 TidbConn.upsert(conn=self.conn, sql_buff=sql)
                 self.conn.commit()