yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-08-19 22:58:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

elastic search logs for further analysis

Browse Source
This commit is contained in:
Na Zhang 2017-02-23 18:11:16 -08:00
parent 156e4a8015
commit c5776985c7
2 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
web/app/dao/AdvSearchDAO.java
View File

@ -214,6 +214,9 @@ public class AdvSearchDAO extends AbstractMySQLOpenSourceDAO
{ {
queryNode.set("query", searchNode); queryNode.set("query", searchNode);
} }
Logger.info(" === AdvSearchDAO::elasticSearch === The query sent to Elastic Search is: " + queryNode.toString());
Promise<WSResponse> responsePromise = WS.url( Promise<WSResponse> responsePromise = WS.url(
Play.application().configuration().getString( Play.application().configuration().getString(
SearchDAO.ELASTICSEARCH_DATASET_URL_KEY)).post(queryNode); SearchDAO.ELASTICSEARCH_DATASET_URL_KEY)).post(queryNode);
@ -286,6 +289,8 @@ public class AdvSearchDAO extends AbstractMySQLOpenSourceDAO
queryNode.set("query", searchNode); queryNode.set("query", searchNode);
} }
Logger.info(" === AdvSearchDAO::elasticSearchMetric === The query sent to Elastic Search is: " + queryNode.toString());
Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString( Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString(
SearchDAO.ELASTICSEARCH_METRIC_URL_KEY)).post(queryNode); SearchDAO.ELASTICSEARCH_METRIC_URL_KEY)).post(queryNode);
JsonNode responseNode = responsePromise.get(1000).asJson(); JsonNode responseNode = responsePromise.get(1000).asJson();
@ -372,6 +377,8 @@ public class AdvSearchDAO extends AbstractMySQLOpenSourceDAO
queryNode.set("query", searchNode); queryNode.set("query", searchNode);
} }
Logger.info(" === AdvSearchDAO::elasticSearchFlowJobs === The query sent to Elastic Search is: " + queryNode.toString());
Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString( Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString(
SearchDAO.ELASTICSEARCH_FLOW_URL_KEY)).post(queryNode); SearchDAO.ELASTICSEARCH_FLOW_URL_KEY)).post(queryNode);
JsonNode responseNode = responsePromise.get(1000).asJson(); JsonNode responseNode = responsePromise.get(1000).asJson();

10
web/app/dao/SearchDAO.java
View File

@ -218,13 +218,13 @@ public class SearchDAO extends AbstractMySQLOpenSourceDAO
queryNode.put("query",funcScoreNodesWrapper); queryNode.put("query",funcScoreNodesWrapper);
Logger.debug("The query sent to Elastic Search is: " + queryNode.toString()); Logger.info(" === elasticSearchDatasetByKeyword === The query sent to Elastic Search is: " + queryNode.toString());
Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString( Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString(
SearchDAO.ELASTICSEARCH_DATASET_URL_KEY)).post(queryNode); SearchDAO.ELASTICSEARCH_DATASET_URL_KEY)).post(queryNode);
responseNode = responsePromise.get(1000).asJson(); responseNode = responsePromise.get(1000).asJson();
Logger.debug("The responseNode from Elastic Search is: " + responseNode.toString()); // Logger.debug("The responseNode from Elastic Search is: " + responseNode.toString());
} }
@ -324,6 +324,9 @@ public class SearchDAO extends AbstractMySQLOpenSourceDAO
if (keywordNode != null) if (keywordNode != null)
{ {
queryNode.set("query", keywordNode); queryNode.set("query", keywordNode);
Logger.info(" === elasticSearchMetricByKeyword === The query sent to Elastic Search is: " + queryNode.toString());
Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString( Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString(
SearchDAO.ELASTICSEARCH_METRIC_URL_KEY)).post(queryNode); SearchDAO.ELASTICSEARCH_METRIC_URL_KEY)).post(queryNode);
responseNode = responsePromise.get(1000).asJson(); responseNode = responsePromise.get(1000).asJson();
@ -434,6 +437,9 @@ public class SearchDAO extends AbstractMySQLOpenSourceDAO
if (keywordNode != null) if (keywordNode != null)
{ {
queryNode.set("query", keywordNode); queryNode.set("query", keywordNode);
Logger.info(" === elasticSearchFlowByKeyword === The query sent to Elastic Search is: " + queryNode.toString());
Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString( Promise<WSResponse> responsePromise = WS.url(Play.application().configuration().getString(
SearchDAO.ELASTICSEARCH_FLOW_URL_KEY)).post(queryNode); SearchDAO.ELASTICSEARCH_FLOW_URL_KEY)).post(queryNode);
responseNode = responsePromise.get(1000).asJson(); responseNode = responsePromise.get(1000).asJson();