|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
import urllib2, re, json, socket
import sys
URL = "http://vocms00170:2113"
SQL = "select \
r.RUNNUMBER,\
r.START_TIME,\
r.RUN_TRIGGERS,\
r.RUN_TYPE\
from \
hcal.runs r \
where \
r.RUN_GLOBAL = 0 and \
(r.runnumber >= :rf or :rf = 0) and \
(r.runnumber <= :rt or :rt = 0) \
order by \
r.runnumber"
TIME = "select to_char(p.time,'YYYY-MM-DD HH24:MI:SS') time from hcal.run_parameters p where p.name like '%TRIGGERS'"
def query(query):
resp = urllib2.urlopen(URL + "/query", query)
if "getcode" in dir(resp) and resp.getcode() == 200:
return resp.read()
def qstring(qstring):
ps = ""
for k in qstring.keys():
ps += "&" if ps != "" else ""
ps += "%s=%s" % (k, qstring[k])
return ps
def get_single(q, qs):
req = urllib2.Request("%s/query/%s/data?%s" % (URL, query(q), qstring(qs)), headers={"Accept" : "application/json"})
resp = urllib2.urlopen(req)
if "getcode" in dir(resp) and resp.getcode() == 200:
ret = json.loads(resp.read())
if len(ret["data"]) > 0:
return ret["data"][0][0]
return None
def get_all(q, qs):
qid = query(q)
ps = qstring(qs)
u = "%s/query/%s/count?%s" % (URL, qid, ps)
resp = urllib2.urlopen(u)
if "getcode" in dir(resp) and resp.getcode() == 200:
data = []
c = int(resp.read())
p = 1
while c > 0:
u = "%s/query/%s/page/1000/%d/data?%s" % (URL, qid, p, ps)
req = urllib2.Request(u, headers={"Accept" : "application/json"})
resp = urllib2.urlopen(req)
if "getcode" in dir(resp) and resp.getcode() == 200:
j = json.loads(resp.read())
data.extend(j["data"])
p += 1
c -= 1000
return data
return None
def main(rf, rt):
ps = {}
if rf != None: ps["rf"] = rf
if rt != None: ps["rt"] = rt
data = get_all(SQL, ps)
for r in data:
if r[3] != None:
for t in ["pedestal","LED","laser"]:
if re.search(t, r[3], flags=re.IGNORECASE) != None:
d = get_single(TIME, { "p.run": int(r[0])})
if d is not None:
d = "\"" + d + "\""
print(r[0], t, d, r[2])
break
if __name__ == '__main__':
rf = sys.argv[1] if len(sys.argv) > 1 else "-"
rt = sys.argv[2] if len(sys.argv) > 2 else "-"
rf = int(rf) if rf.isdigit() else 0
rt = int(rt) if rt.isdigit() else 0
main(rf, rt)
|