update

write_data_into_es/revise_data_from_es.py

@@ -69,8 +69,8 @@ for one_scan in write_into_scan:
     bulk_one_body = bulk_head + '\n' + data_str + '\n'
     print(bulk_one_body)
     bulk_all_body += bulk_one_body
-    break
-    if count%100 == 0:
+    # break
+    if count%500 == 0:
 
          eror_dic=es7.bulk(index=target_index,
                 body=bulk_all_body, request_timeout=200)