update sql

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -78,7 +78,7 @@ def update_tag3_user_portrait(cl_id):
 
 def consume_kafka():
     # TODO 30
-    sql = "select distinct cl_id from kafka_tag3_log where time > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 5 day))"
+    sql = "select distinct cl_id from kafka_tag3_log where log_time > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 5 day))"
     db, cursor = get_jerry_test()
     cursor.execute(sql)
     device_ids_lst = [i[0] for i in cursor.fetchall()]