切换elk

crawler_process.py

@@ -17,7 +17,7 @@ from utils.tas_redis import task_redis
 
 
 logger = get_logger('crawler_process')
 logger = get_logger('crawler_process')
 dashboard = MySqlOperator('dashboard')
 dashboard = MySqlOperator('dashboard')
-ichunt_elk = Elasticsearch(host="127.0.0.1", port=9200, timeout=20)
+ichunt_elk = Elasticsearch(host="172.18.137.50", port=9200, timeout=20)
 
 
 
 
 def get_process_task(task_code):
 def get_process_task(task_code):
@@ -30,7 +30,7 @@ def get_process_task(task_code):
 
 
 def get_error_ratio(task_code, time_range=30):
 def get_error_ratio(task_code, time_range=30):
     utc_since = datetime.utcnow() - timedelta(minutes=time_range)
     utc_since = datetime.utcnow() - timedelta(minutes=time_range)
-    index = 'logstash-' + utc_since.strftime('%Y.%m.%d')
+    index = 'spider_logs-' + utc_since.strftime('%Y.%m.%d')
     query = {
     query = {
         "size": 0,
         "size": 0,
         "query": {
         "query": {