| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 | # Author renyupeng# coding=utf-8# @Time    : 2021/9/27 10:50 上午# @Site    :# @File    : MaterialCost.py# @Software: PyCharm# @contact: renyupeng@c-top.com.cn# @Tel 1501435553import loggingfrom math import ceilfrom Apietl.utlis.Utils import Utilsfrom Apietl.conn.TidbConn import TidbConnclass signature_photo_Id:    def __init__(self):        self.conn = TidbConn.get_connection()        self.parm = Utils.get_args()    def daily_report(self):        try:            sql = """        replace into media_api.signature_photo_id    select signature,photo_id,photo_name,channel_type    from                      media_api.kuaishou_video_list    where signature is not null and photo_id is not null and date_format(stat_date,'%Y%m%d')>=date_format(date_sub(now(),interval 2 day),'%Y%m%d')    group by signature,photo_id    """            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 = signature_photo_Id().daily_report()    if status == 0:        print("作业执行成功")        exit(0)    else:        print("作业执行失败")        exit(-1)
 |