Skip to content

Turn queryString into a dict in evhc_grafana_jobs #99

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
mmascher wants to merge 2 commits into
base: master
Choose a base branch
from
Open

Turn queryString into a dict in evhc_grafana_jobs #99

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
84a51aa
Turn queryString into a dict in evhc_grafana_jobs
mmascher Sep 7, 2020
5c2f2e7
Merge branch 'master' of https://github.com/CMSCompOps/MonitoringScri…
mmascher Sep 7, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
60 changes: 44 additions & 16 deletions hammercloud/eval_hc.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,10 @@
os.environ["HADOOP_CONF_DIR"] = "/opt/hadoop/conf/etc/analytix/hadoop.analytix"
os.environ["JAVA_HOME"] = "/etc/alternatives/jre"
os.environ["HADOOP_PREFIX"] = "/usr/hdp/hadoop"
import pydoop.hdfs
try:
import pydoop.hdfs
except:
pass
# ########################################################################### #


Expand Down Expand Up @@ -295,7 +298,7 @@ def evhc_template_cfg():



def evhc_grafana_jobs(startTIS, limitTIS):
def evhc_grafana_jobs(startTIS, limitTIS, mustClauses=None):
"""function to fetch HammerCloud HTCondor job records via Grafana"""
# ############################################################# #
# fill global HTCondor list with job records from ElasticSearch #
Expand All @@ -313,19 +316,42 @@ def evhc_grafana_jobs(startTIS, limitTIS):

# prepare Lucene ElasticSearch query:
# ===================================
queryString = ("{\"search_type\":\"query_then_fetch\",\"index\":[\"monit" +
"_prod_condor_raw_metric*\"]}\n{\"query\":{\"bool\":{\"mu" +
"st\":[{\"match_phrase\":{\"data.metadata.spider_source\"" +
":\"condor_history\"}},{\"match_phrase\":{\"data.CRAB_Use" +
"rHN\":\"sciaba\"}}],\"filter\":{\"range\":{\"data.Record" +
"Time\":{\"gte\":%d,\"lt\":%d,\"format\":\"epoch_second\"" +
"}}}}},\"_source\":{\"includes\":[\"data.GlobalJobId\",\"" +
"data.Site\",\"data.Status\",\"data.NumRestarts\",\"data." +
"RemoveReason\",\"data.Chirp_CRAB3_Job_ExitCode\",\"data." +
"ExitCode\",\"data.CRAB_Workflow\",\"data.CRAB_Id\",\"dat" +
"a.CRAB_Retry\",\"data.RecordTime\"]},\"track_total_hits" +
"\":true,\"size\":8192,\"search_after\":[%%d],\"sort\":[{" +
"\"data.RecordTime\":\"asc\"}]}\n") % (startTIS, limitTIS)
queryType = {
"search_type": "query_then_fetch",
"index": ["monit_prod_condor_raw_metric*"]
}
source = {
'includes': ['data.GlobalJobId', 'data.Site', 'data.Status',
'data.NumRestarts', 'data.RemoveReason',
'data.Chirp_CRAB3_Job_ExitCode', 'data.ExitCode',
'data.CRAB_Workflow', 'data.CRAB_Id', 'data.CRAB_Retry',
'data.RecordTime']
}
query = {
'bool': {
'must': [
{'match_phrase': {'data.metadata.spider_source':
'condor_history'}},
{'match_phrase': {'data.CRAB_UserHN': 'sciaba'}}
],
'filter': {
'range': {
'data.RecordTime': {
'gte': int(startTIS),
'lt': int(limitTIS),
'format': 'epoch_second'}
}
}
},
}
query['bool']['must'].extend(mustClauses or [])
totalQuery = {
'query' : query,
'_source' : source,
'size': 8192,
'search_after': [ None ], # Filled later
'sort': [ {'data.RecordTime': 'asc'} ]
}

# prepare regular expression for HammerCloud CRAB workflow name match:
# ====================================================================
Expand All @@ -341,9 +367,11 @@ def evhc_grafana_jobs(startTIS, limitTIS):
#
# fetch chunk job records from ElasticSearch:
# ===========================================
totalQuery['search_after'][0] = int(afterTImS)
queryString = json.dumps(queryType) + '\n' + json.dumps(totalQuery) + '\n'
try:
requestObj = urllib.request.Request(URL_GRAFANA,
data=(queryString % afterTImS).encode("utf-8"),
data=queryString.encode("utf-8"),
headers=HDR_GRAFANA, method="POST")
responseObj = urllib.request.urlopen( requestObj, timeout=60 )
#
Expand Down