Merge branch 'offic' into 'master'

update datetime format

See merge request !77

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -327,7 +327,7 @@ def update_tag3_user_portrait(cl_id):
 
 
 def consume_kafka():
-    start = datetime.datetime.now()
+    start = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
     sql = "select distinct cl_id from kafka_tag3_log where log_time > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 30 day))"
     db, cursor = get_doris_prod()
     cursor.execute(sql)
@@ -361,7 +361,7 @@ def consume_kafka():
         # result2.foreach(print)
         # result2.collect()
 
-        end = datetime.datetime.now()
+        end = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
         msg_dict = {"start": str(start), "end": str(end), "device_number": len(device_ids_lst)}
         msg_res = ""
         for (k, v) in msg_dict.items():