overflow_backup_2018_0455/mongodb_crawler_java
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

.

Browse Source
This commit is contained in:
jackdaw@loafle.com 2017-04-14 10:45:28 +09:00
parent 993d862a53
commit 79c547217a
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java
View File

@ -1,6 +1,7 @@
package com.loafle.overflow.crawler.mongo; package com.loafle.overflow.crawler.mongo;
import com.loafle.overflow.crawler.Crawler; import com.loafle.overflow.crawler.Crawler;
import com.loafle.overflow.crawler.config.Config;
import com.mongodb.MongoClient; import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase; import com.mongodb.client.MongoDatabase;
import org.bson.Document; import org.bson.Document;
@ -39,9 +40,10 @@ public class MongoCrawler extends Crawler {
} }
@Override @Override
public Object getInternal(Map<String, Object> map) throws Exception { public Object getInternal(Config config) throws Exception {
Map<String ,Object> re = collectMetric((String) map.get("ip"), (String)map.get("port"), (String)map.get("dbName")); //Map<String ,Object> re = collectMetric((String) map.get("ip"), (String)map.get("port"), (String)map.get("dbName"));
System.out.println("re = " + re); //System.out.println("re = " + re);
return re; //return re;
return null;
} }
} }