+def build_elastic_search_JSON_request(query_String):
+ data = {
+ "from": "0",
+ "size": "1",
+ "sort": [{"TimeStamp": {"order": "desc"}}],
+ "query": {"query_string": {"query": query_String}},
+ }
+ return json.dumps(data)
+
+
+def create_query_string_search(data_category, metric_name, node_id, rk_node_id):
+ query = "TSDRDataCategory:"
+ query += data_category
+ query += " AND MetricName:"
+ query += metric_name
+ query += ' AND NodeID:"'
+ query += node_id
+ query += '" AND RecordKeys.KeyValue:"'
+ query += rk_node_id
+ query += '" AND RecordKeys.KeyName:Node AND RecordKeys.KeyValue:0 AND RecordKeys.KeyName:Table'
+ return query
+
+
+def create_query_string_count(data_category):
+ query = "TSDRDataCategory:"
+ query += data_category
+ return query
+
+
+def extract_metric_value_search(response):
+ return str(response["hits"]["hits"][0]["_source"]["MetricValue"])
+
+
+def extract_metric_value_count(response):
+ return int(response["hits"]["total"])
+
+