update

crawler_process.py

@@ -133,7 +133,6 @@ def main():
     while 1:
     while 1:
         try:
         try:
             pi = get_crawler_process_info()
             pi = get_crawler_process_info()
-            print(pi)
             info_update(pi)
             info_update(pi)
         except Exception:
         except Exception:
             logger.error(traceback.format_exc())
             logger.error(traceback.format_exc())

utils/es_api.py

@@ -90,7 +90,7 @@ def get_task_error_rate(time_range=30, error_rate=30):
         "query": {
         "query": {
             "range": {
             "range": {
                 "@timestamp": {
                 "@timestamp": {
-                    "gte": utc_since.strftime("%Y-%m-%dT%H:%M:%SZ")
+                    "gte": utc_since.strftime("%Y-%m-%dT%H:%M:%S.000Z")
                 }
                 }
             }
             }
         },
         },