From a5d1969d491dea91c7c51776411d54973349a04f Mon Sep 17 00:00:00 2001 From: "jackdaw@loafle.com" Date: Wed, 26 Apr 2017 11:03:52 +0900 Subject: [PATCH] config metric test --- .../overflow/crawler/mongo/MongoCrawler.java | 32 ++++--------------- src/test/resources/config/example.json | 31 ++++++++---------- 2 files changed, 19 insertions(+), 44 deletions(-) diff --git a/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java b/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java index 5913ce6..b7dc5fb 100644 --- a/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java +++ b/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java @@ -3,7 +3,6 @@ package com.loafle.overflow.crawler.mongo; import com.loafle.overflow.crawler.Crawler; import com.loafle.overflow.crawler.config.Config; import com.loafle.overflow.crawler.config.Item; -import com.loafle.overflow.crawler.config.Query; import com.loafle.overflow.crawler.result.OFResultSet; import com.loafle.overflow.crawler.result.OFResultSetCol; import com.mongodb.MongoClient; @@ -13,18 +12,14 @@ import com.mongodb.client.MongoDatabase; import org.bson.Document; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; - - public class MongoCrawler extends Crawler { public Object collectMetric(Config c) throws Exception { MongoClient mongoClient = null; -// Map returnMap = new HashMap(); String dataBaseName = null; String statusCommand = null; @@ -48,36 +43,21 @@ public class MongoCrawler extends Crawler { for (Item item : items) { row = new ArrayList<>(); - ofResultSet = new OFResultSetCol(item); - Query query = item.getQuery(); - dataBaseName = (String)item.getQuery().getQueryInfo().get("dataBaseName"); - statusCommand = (String)item.getQuery().getQueryInfo().get("statusCommand"); + dataBaseName = (String)item.getQueryInfo().get("dataBaseName"); + statusCommand = (String)item.getQueryInfo().get("statusCommand"); MongoDatabase database = mongoClient.getDatabase(dataBaseName); Document serverStatus = database.runCommand(new Document(statusCommand, 1)); - - Map re = (Map)serverStatus.get(query.getQueryInfo().get("query")); - -// Map resultMap = new HashMap(); -// for (Map.Entry set : serverStatus.entrySet()){ -// resultMap.put(set.getKey(), set.getValue()); -// } - - - -// Map re = (Map) resultMap.get(query.getQueryInfo().get("query")); - - for (int index =0 ; index < query.getKeys().size() ; ++index) { - row.add(String.valueOf(re.get(query.getKeys().get(index)))); + Map re = (Map)serverStatus.get(item.getQueryInfo().get("query")); + for (int index =0 ; index < item.getKeys().size() ; ++index) { + row.add(String.valueOf(re.get(item.getKeys().get(index)))); } - + ofResultSet.addRow(row); - ofResultSets.add(ofResultSet); - } }catch (Exception e) { throw e; diff --git a/src/test/resources/config/example.json b/src/test/resources/config/example.json index 5e43f4f..bd22264 100644 --- a/src/test/resources/config/example.json +++ b/src/test/resources/config/example.json @@ -28,24 +28,19 @@ "memory.usage.mapped", "memory.usage.mappedWithJournal" ], - "query": - { - "queryInfo": { - "query":"mem", - "dataBaseName":"admin", - "statusCommand":"serverStatus", - "parseDirection" : "col" - }, - "keys" : [ - "bits", - "resident", - "virtual", - "supported", - "mapped", - "mappedWithJournal" - ] - } - + "queryInfo": { + "query":"mem", + "dataBaseName":"admin", + "statusCommand":"serverStatus" + }, + "keys" : [ + "bits", + "resident", + "virtual", + "supported", + "mapped", + "mappedWithJournal" + ] } ] } \ No newline at end of file