| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 | # Author zhaohailiang# coding=utf-8# @Time    : 2022/01/19 21:10 下午# @Site    :# @File    : KuaishouNewMaterialNumInProject.py# @Software: PyCharm# @contact: zhaohailiang@c-top.com.cn# @Tel 18201631162import loggingfrom Apietl.conn.TidbConn import TidbConnfrom Apietl.utlis.Utils import Utilsclass 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_projectselect create_time as stat_date, 2 as media_id,project_id,count(*) as material_num from (select create_time,project_id,signature from application.kuaishou_project_material_relation awhere create_time>={date_time})tgroup by create_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 -1if __name__ == '__main__':    status = KuaishouNewMaterialNumInProject().taskHandler()    if status == 0:        print("作业执行成功")        exit(0)    else:        print("作业执行失败")        exit(-1)
 |