update db

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -278,7 +278,7 @@ def update_tag3_user_portrait(cl_id):
 
 
 def consume_kafka():
-    sql = "select distinct cl_id from kafka_tag3_log where log_time > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 60 day))"
+    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)
     device_ids_lst = [i[0] for i in cursor.fetchall()]

eda/smart_rank/tool.py

@@ -398,7 +398,7 @@ def get_tag3_user_log(cl_id):
                  second_demands, first_positions, second_positions, projects
                  from kafka_tag3_log where cl_id = '{}'""".format(cl_id)
 
-        db, cursor = get_jerry_test()
+        db, cursor = get_doris_prod()
         cursor.execute(sql)
         data = list(cursor.fetchall())
         db.close()