renyupeng 3 年之前
父节点
当前提交
4efdf3646f
共有 1 个文件被更改,包括 7 次插入10 次删除
  1. 7 10
      Apietl/kwai_etl/report/AppKuaiShouAgentReport.py

+ 7 - 10
Apietl/kwai_etl/report/AppKuaiShouAgentReport.py

@@ -12,8 +12,6 @@ from Apietl.conn.TidbConn import TidbConn
 from Apietl.utlis.Utils import Utils
 
 
-
-
 class AppKuaishouAgentReport:
     def __init__(self):
         self.conn = TidbConn.get_connection()
@@ -21,8 +19,8 @@ class AppKuaishouAgentReport:
         self.date_time = self.parm[0]
 
     def taskHandler(self):
-     try:
-      sql = """
+        try:
+            sql = """
     SET sql_mode = 'STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION';
 replace into `application`.`app_kuaishou_agent_report_d`
 (
@@ -143,11 +141,11 @@ WHERE
 cua.account_id IS NOT NULL) bei
 ON report.advertiser_id = bei.account_id;
  """.format(date_time=self.date_time)
-      TidbConn.upsert(conn=self.conn, sql_buff=sql)
-      self.conn.commit()
-      TidbConn.conn_close(conn=self.conn)
-      return 0
-     except Exception as e:
+            TidbConn.upsert(conn=self.conn, sql_buff=sql)
+            self.conn.commit()
+            TidbConn.conn_close(conn=self.conn)
+            return 0
+        except Exception as e:
             logging.error(e)
             return -1
 
@@ -159,4 +157,3 @@ if __name__ == '__main__':
         exit(0)
     else:
         print("作业执行失败")
-