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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
#! python
import cgi
import cgitb
import os
import sys
import re
import datetime
STEUERMANN_DIR_HERE
sys.path.insert(0, addpath)
import steuermann.config
cgitb.enable()
form = cgi.FieldStorage(keep_blank_values=1)
cginame = os.getenv("SCRIPT_NAME")
def sqltime(arg) :
if arg is None :
return None
if '.' in arg :
x = arg.split('.')
d = datetime.datetime.strptime(x[0],'%Y-%m-%d %H:%M:%S')
d = d.replace(microsecond=int((x[1]+'000000')[0:6]))
else :
x = time.strptime(arg,'%Y-%m-%d %H:%M:%S')
d = datetime.datetime(year=x[0], month=x[1], day=x[2],
hour=x[3], minute=x[4], second=x[5] )
# not in 2.4:
# d = datetime.datetime.strptime(arg,'%Y-%m-%d %H:%M:%S')
return d
##########
# if no action specified, show the list of runs
#
if not 'action' in form :
print 'content-type: text/html'
print ''
db = steuermann.config.open_db()
c = db.cursor()
c.execute('SELECT DISTINCT run FROM sm_status ORDER BY run DESC')
for run, in c :
print "<a href=%s?action=status&run=%s>%s</a><br>"%(cginame, run, run)
sys.exit(0)
action = form['action'].value
##########
# status means show the status of a particular run
#
if action == 'status' :
db = steuermann.config.open_db()
import steuermann.report
steuermann.report.cginame = cginame
print 'content-type: text/html'
print ''
run = form['run'].value
print steuermann.report.report_html( db, run, info_callback=steuermann.report.info_callback_gui )
sys.exit(0)
##########
# log means show the result of a particular node from a run
#
elif action == 'log' :
print 'content-type: text/plain'
print ''
# crack apart the parameter run/host:table/cmd
name = re.match('(.*)/(.*):(.*)/(.*)', form['name'].value)
run = name.group(1)
host = name.group(2)
table = name.group(3)
cmd = name.group(4)
db = steuermann.config.open_db()
c = db.cursor()
c.execute("SELECT status, start_time, end_time, notes FROM sm_status WHERE run = ? AND host = ? AND tablename = ? AND cmd = ?",(
run, host, table, cmd ) )
x = c.fetchone()
if x is None :
print "No such record in database",run,host,table,cmd
sys.exit(0)
status, start_time, end_time, notes = x
print "%s %s:%s/%s"%(run, host, table, cmd)
print "status: %s"%status
print ""
print "start: %s"%start_time
print "end : %s"%end_time
start_time = sqltime(start_time)
end_time = sqltime(end_time)
if isinstance(end_time,datetime.datetime) and isinstance(end_time,datetime.datetime) :
print "dur : %s"%(end_time-start_time)
if not notes is None :
print "notes:"
for x in [ ' ' + x for x in notes.split('\n') ] :
print x
print ""
filename = '%s/%s/%s:%s.%s.log'%(steuermann.config.logdir,run,host,table,cmd)
try :
f=open(filename,'r')
except IOError:
print "No log file %s" %filename
f = None
print "--------------------"
if f :
while 1 :
x = f.read(65536)
if x == '' :
break
sys.stdout.write(x)
sys.exit(0)
##########
# info means show information about the system
#
elif action == 'info' :
print 'content-type: text/html\n'
print 'db credentials: ',steuermann.config.db_creds,'<br>'
print 'logdir: ',steuermann.config.logdir,'<br>'
db = steuermann.config.open_db()
cur = db.cursor()
cur.execute("select count(*) from sm_status")
l = cur.fetchone()
print "database records: %s\n"%l[0],'<br>'
cur.execute("select count(*) from sm_runs")
l = cur.fetchone()
print "runs: %s\n"%l[0],'<br>'
sys.exit(0)
##########
print 'content-type: text/html'
print ''
print 'no recognized action?'
|
