renyupeng 3 年之前
父节点
当前提交
77f97d8675

+ 2 - 5
Apietl/kwai_etl/report/CampaignDailyReport.py

@@ -219,10 +219,7 @@ class CampaignDailyReport:
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     status = CampaignDailyReport().daily_report()
     status = CampaignDailyReport().daily_report()
-    media_name = 'kwai'
-    trace_log = Logger().etl_logger(media_name, CampaignDailyReport().start_time)
-
     if status == 0:
     if status == 0:
-        trace_log.info("作业执行成功")
+        print("作业执行成功")
     else:
     else:
-        trace_log.error("作业执行失败")
+        print("作业执行失败")

+ 2 - 4
Apietl/kwai_etl/report/CampaignHourlyReport.py

@@ -218,9 +218,7 @@ class CampaignHourlyReport:
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     status = CampaignHourlyReport().hourly_report()
     status = CampaignHourlyReport().hourly_report()
-    media_name = 'kwai'
-    trace_log = Logger().etl_logger(media_name, CampaignHourlyReport().start_time)
     if status == 0:
     if status == 0:
-        trace_log.info("作业执行成功")
+        print("作业执行成功")
     else:
     else:
-        trace_log.error("作业执行失败")
+        print("作业执行失败")

+ 3 - 6
Apietl/kwai_etl/report/MateirialVideoDailyReport.py

@@ -282,8 +282,7 @@ from media_api.kuaishou_material_video_report_daily report
  where report.stat_date between {start_time} and {end_time} and  report.photo_id!=0
  where report.stat_date between {start_time} and {end_time} and  report.photo_id!=0
   order by advertiser_id,photo_id ,stat_date limit {num},20000""".format(
   order by advertiser_id,photo_id ,stat_date limit {num},20000""".format(
                     start_time=self.start_time, end_time=self.end_time, num=i * 20000)
                     start_time=self.start_time, end_time=self.end_time, num=i * 20000)
-                trace_log1 = Logger().etl_logger('kwai', MateirialVideoDailyReport().start_time)
-                trace_log1.info(sql)
+                print(sql)
                 TidbConn.exec_sql(self.conn, sql)
                 TidbConn.exec_sql(self.conn, sql)
                 self.conn.commit()
                 self.conn.commit()
             return 0
             return 0
@@ -294,9 +293,7 @@ from media_api.kuaishou_material_video_report_daily report
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     status = MateirialVideoDailyReport().daily_report()
     status = MateirialVideoDailyReport().daily_report()
-    media_name = 'kwai'
-    trace_log = Logger().etl_logger(media_name, MateirialVideoDailyReport().start_time)
     if status == 0:
     if status == 0:
-        trace_log.info("作业执行成功")
+        print("作业执行成功")
     else:
     else:
-        trace_log.error("作业执行失败")
+        print("作业执行失败")

+ 2 - 4
Apietl/kwai_etl/report/MateirialVideoHourlyReport.py

@@ -292,9 +292,7 @@ from media_api.kuaishou_material_video_report_hourly report
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     status = MateirialVideoHourlyReport().hourly_report()
     status = MateirialVideoHourlyReport().hourly_report()
-    media_name = 'kwai'
-    trace_log = Logger().etl_logger(media_name, MateirialVideoHourlyReport().start_time)
     if status == 0:
     if status == 0:
-        trace_log.info("作业执行成功")
+        print("作业执行成功")
     else:
     else:
-        trace_log.error("作业执行失败")
+        print("作业执行失败")

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

@@ -221,9 +221,7 @@ class UnitDailyReport:
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     status = UnitDailyReport().daily_report()
     status = UnitDailyReport().daily_report()
-    media_name = 'kwai'
-    trace_log = Logger().etl_logger(media_name, UnitDailyReport().start_time)
     if status == 0:
     if status == 0:
-        trace_log.info("作业执行成功")
+        print("作业执行成功")
     else:
     else:
-        trace_log.error("作业执行失败")
+        print("作业执行失败")

+ 2 - 4
Apietl/kwai_etl/report/UnitHourlyReport.py

@@ -223,9 +223,7 @@ class UnitHourlyReport:
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     status = UnitHourlyReport().hourly_report()
     status = UnitHourlyReport().hourly_report()
-    media_name = 'kwai'
-    trace_log = Logger().etl_logger(media_name, UnitHourlyReport().start_time)
     if status == 0:
     if status == 0:
-        trace_log.info("作业执行成功")
+        print("作业执行成功")
     else:
     else:
-        trace_log.error("作业执行失败")
+        print("作业执行失败")