update

crawler_sys/scheduler/cal_ni_and_put_to_backend.py

@@ -480,9 +480,10 @@ def task_main():
     for res_data in scan_from_redis(rules_list):
         # 符合规则入库数据
         try:
+            print("start to write to es",res_data)
             tractate_id = write_data_into_mysql(res_data)
             # tractate_id = "test"
-            print("line394",tractate_id,res_data)
+            print("down to write to es",tractate_id,res_data)
             if res_data["level"] >= 3 and tractate_id:
                 content = res_data.get("content") if res_data.get("content") else res_data.get("title")
                 title_str = res_data["platform"] + "帖子内容审核"