improve logging

This commit is contained in:
Shinsuke Sugaya 2021-04-22 14:59:13 +09:00
parent 109c012f16
commit 3e09e5b645
2 changed files with 3 additions and 1 deletions

View file

@ -206,6 +206,7 @@ public class CrawlTestBase extends ITBase {
final List<Map<String, Object>> logList = readLogItems("crawlinginfo");
final List<Map<String, Object>> resList = new ArrayList<>();
for (Map<String, Object> elem : logList) {
logger.info("config_id: {}, session_id: {}", configId, elem.containsKey("session_id"));
if (elem.containsKey("session_id") && elem.get("session_id").equals(configId)) {
resList.add(elem);
}
@ -217,6 +218,7 @@ public class CrawlTestBase extends ITBase {
final List<Map<String, Object>> logList = readLogItems("failureurl");
final List<Map<String, Object>> resList = new ArrayList<>();
for (Map<String, Object> elem : logList) {
logger.info("config_id: {}, thread_name: {}", configId, elem.containsKey("thread_name"));
if (elem.containsKey("thread_name") && elem.get("thread_name").toString().startsWith("Crawler-" + configId)) {
resList.add(elem);
}

View file

@ -64,7 +64,7 @@ public class CrawlerLogTests extends CrawlTestBase {
webConfigId = getWebConfigIds(NAME_PREFIX).get(0);
createJob();
logger.info("Job is created");
logger.info("Job is created: {}", webConfigId);
refresh();
startJob(NAME_PREFIX);