update field

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -191,9 +191,6 @@ def consume_kafka():
     db.close()
     cursor.close()
 
-    # TODO
-    device_ids_lst = ["androidid_a25a1129c0b38f7b"]
-
     sparkConf = SparkConf().set("spark.hive.mapred.supports.subdirectories", "true") \
                            .set("spark.hadoop.mapreduce.input.fileinputformat.input.dir.recursive", "true") \
                            .set("spark.tispark.plan.allow_index_double_read", "false") \
@@ -226,7 +223,9 @@ def consume_kafka():
 
 if __name__ == "__main__":
     start = datetime.datetime.now()
-    consume_kafka()
+    update_tag3_user_portrait("androidid_a25a1129c0b38f7b")
+    # TODO
+    # consume_kafka()
     end = datetime.datetime.now()
     print(end - start)
     print("done")