# Author renyupeng # coding=utf-8 # @Time : 2021/11/17 3:40 下午 # @Site : # @File : BytedanceMaterialMd5FristCostDateUpdate.py # @Software: PyCharm # @contact: renyupeng@c-top.com.cn # @Tel 1501435553 import datetime import logging from Apietl.conn.TidbConn import TidbConn from Apietl.conn.TidbProConn import TidbProConn from Apietl.utlis.Utils import Utils class BytedanceMaterialMd5FristCostDateUpdate: def __init__(self): self.conn = TidbProConn.get_connection() self.Innerconn = TidbConn.get_connection() self.parm = Utils.get_args() self.start_time = self.parm[0] self.end_time = self.parm[1] def TaskHandler(self): try: sql = """ replace into application.bytedance_material_md5_frist_cost_time select a.material_id,a.signature, case when b.first_cost_time is null then a.stat_datetime when a.stat_datetime