renyupeng 2 лет назад
Родитель
Сommit
ed1454f633

+ 49 - 0
Apietl/task/BytedanceNewMaterialNumInProject.py

@@ -0,0 +1,49 @@
+# Author zhaohailiang
+# coding=utf-8
+# @Time    : 2022/01/19 21:10 下午
+# @Site    :
+# @File    : BytedanceNewMaterialNumInProject.py
+# @Software: PyCharm
+# @contact: zhaohailiang@c-top.com.cn
+# @Tel 18201631162
+import logging
+
+from Apietl.conn.TidbConn import TidbConn
+from Apietl.utlis.Utils import Utils
+
+
+class BytedanceNewMaterialNumInProject:
+    def __init__(self):
+        self.conn = TidbConn.get_connection()
+        self.parm = Utils.get_task_args()
+        self.date_time = self.parm[0]
+
+    def taskHandler(self):
+        try:
+            sql = """
+            replace into application.new_material_num_in_project
+select media_time as stat_date, 1 as media_id,project_id,count(*) as material_num from (
+select media_time,project_id,signature from application.bytedance_project_material_relation a
+left join application.app_bytedance_material_info b
+on a.signature=b.material_id
+where media_time={date_time})t
+group by media_time,project_id
+            """.format(date_time=self.date_time)
+            print(sql)
+            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
+
+
+if __name__ == '__main__':
+    status = BytedanceNewMaterialNumInProject().taskHandler()
+    if status == 0:
+        print("作业执行成功")
+        exit(0)
+    else:
+        print("作业执行失败")
+        exit(-1)

+ 49 - 0
Apietl/task/KuaishouNewMaterialNumInProject.py

@@ -0,0 +1,49 @@
+# Author zhaohailiang
+# coding=utf-8
+# @Time    : 2022/01/19 21:10 下午
+# @Site    :
+# @File    : KuaishouNewMaterialNumInProject.py
+# @Software: PyCharm
+# @contact: zhaohailiang@c-top.com.cn
+# @Tel 18201631162
+import logging
+
+from Apietl.conn.TidbConn import TidbConn
+from Apietl.utlis.Utils import Utils
+
+
+class KuaishouNewMaterialNumInProject:
+    def __init__(self):
+        self.conn = TidbConn.get_connection()
+        self.parm = Utils.get_task_args()
+        self.date_time = self.parm[0]
+
+    def taskHandler(self):
+        try:
+            sql = """
+            replace into application.new_material_num_in_project
+select media_time, 2 as media_id,project_id,count(*) from (
+select media_time,project_id,signature from application.kuaishou_project_material_relation a
+left join application.app_kuaishou_material_info b
+on a.signature=b.material_id
+where media_time=${stat_date})t
+group by media_time,project_id
+            """.format(date_time=self.date_time)
+            print(sql)
+            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
+
+
+if __name__ == '__main__':
+    status = KuaishouNewMaterialNumInProject().taskHandler()
+    if status == 0:
+        print("作业执行成功")
+        exit(0)
+    else:
+        print("作业执行失败")
+        exit(-1)