update

output/output_article_distribution_0917.py

@@ -201,15 +201,15 @@ for redis_count,spark_res in enumerate(sql_res):
     if redis_count % 5000 == 0:
         print(redis_count,bulk_dict)
         # print(second_demands_tag_count,projects_demands_tag_count)
-
-print(bulk_dict)
-
-print("second_demands_tag_count",second_demands_tag_count)
-print("projects_demands_tag_count",projects_demands_tag_count)
+print(total_tag_count)
+# print(bulk_dict)
+#
+# print("second_demands_tag_count",second_demands_tag_count)
+# print("projects_demands_tag_count",projects_demands_tag_count)
 with open("log.log","w",encoding='utf-8') as f:
-    f.write(bulk_dict)
-    f.write(second_demands_tag_count)
-    f.write(projects_demands_tag_count)
+    f.write(total_tag_count)
+    # f.write(second_demands_tag_count)
+    # f.write(projects_demands_tag_count)