get result

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -267,13 +267,14 @@ def update_tag3_user_portrait(cl_id):
            (len(first_solutions_score.keys()) > 0) or (len(second_solutions_score.keys()) > 0) or \
            (len(first_positions_score.keys()) > 0) or (len(second_positions_score.keys()) > 0) or \
            (len(projects_score.keys()) > 0):
-            redis_client.set(key, json.dumps(res))
-            redis_client.expire(key, 60 * 60 * 24 * 180)
+            # TODO
+            # redis_client.set(key, json.dumps(res))
+            # redis_client.expire(key, 60 * 60 * 24 * 180)
 
-            write_user_portrait(cl_id, ",".join(first_solutions_score.keys()), ",".join(second_solutions_score.keys()),
-                                ",".join(first_demands_score.keys()), ",".join(second_demands_score.keys()),
-                                ",".join(first_positions_score.keys()), ",".join(second_positions_score.keys()),
-                                ",".join(projects_score.keys()))
+            # write_user_portrait(cl_id, ",".join(first_solutions_score.keys()), ",".join(second_solutions_score.keys()),
+            #                     ",".join(first_demands_score.keys()), ",".join(second_demands_score.keys()),
+            #                     ",".join(first_positions_score.keys()), ",".join(second_positions_score.keys()),
+            #                     ",".join(projects_score.keys()))
 
             body = {}
             for (k, v) in res.items():
@@ -334,11 +335,10 @@ def consume_kafka():
 if __name__ == "__main__":
     start = datetime.datetime.now()
 
-    update_tag3_user_portrait("862460044588666")
-    update_tag3_user_portrait("androidid_a25a1129c0b38f7b")
+    # update_tag3_user_portrait("862460044588666")
+    # update_tag3_user_portrait("androidid_a25a1129c0b38f7b")
 
-    # TODO
-    # consume_kafka()
+    consume_kafka()
     end = datetime.datetime.now()
     print(end - start)
     print("done")