lemmon_tools Namespace Reference

Functions
def	runMachineCheck ()
	machine information More...
def	runStatusCheck (MAX_ATTEMPTS=3, verbose=False)
	run LEM status check More...
def	appendToFile (status, prefix="/nusoft/app/web/htdoc/nova/lem/")
	append a status to a file More...
def	appendStatus (history, new)
	append status to statuses More...

Variables
list	SERVERS = ["lem.hep.caltech.edu"]
	PORTS = range(1024, 1032)

Function Documentation

def lemmon_tools.appendStatus	(		history,
			new
	)

append status to statuses

Definition at line 87 of file lemmon_tools.py.

References append().

Referenced by appendToFile().

def appendStatus(history, new):
    history["machine"].append(          new["machine"])
    history["time"].append(             new["time"])
    history["year"].append(             new["year"])
    history["month"].append(            new["month"])
    history["day"].append(              new["day"])
    history["hour"].append(             new["hour"])
    history["minute"].append(           new["minute"])
    history["second"].append(           new["second"])
    history["results"].append(          new["results"])
    return history

def lemmon_tools.appendToFile	(		status,
			prefix = "/nusoft/app/web/htdoc/nova/lem/"
	)

append a status to a file

Definition at line 60 of file lemmon_tools.py.

References appendStatus(), and open().

Referenced by nova::database::Table.BulkInsertInDB(), nova::dbi::Table.LoadFromCSV(), nutools::dbi::Table.LoadFromCSV(), nova::database::Table.UpdateFromSSV(), nova::dbi::Table.WriteToCSV(), and nutools::dbi::Table.WriteToCSV().

def appendToFile(status, prefix="/nusoft/app/web/htdoc/nova/lem/"):
    import os, json
    output_name = "%s/lemmon.json"%(prefix)
    if not os.path.exists(output_name):
        print "tools: output file %s doesn't exist, making a fresh file"%output_name
        statuses = {}
        statuses["servers"] = SERVERS
        statuses["ports"]   = PORTS
        statuses["machine"] = []
        statuses["time"]    = []
        statuses["year"]    = []
        statuses["month"]   = []
        statuses["day"]     = []
        statuses["hour"]    = []
        statuses["minute"]  = []
        statuses["second"]  = []
        statuses["results"] = []
    else:
        print "tools: loading output file"
        statuses = json.load(open(output_name,"r"))
    print "tools: Appending to list of %i statuses"%len(statuses["time"])
    statuses = appendStatus(statuses, status)
    with open(output_name, "w") as outfile:
        json.dump(statuses, outfile)
    print "tools: written to %s"%output_name

def lemmon_tools.runMachineCheck

(

)

machine information

Definition at line 6 of file lemmon_tools.py.

Referenced by runStatusCheck().

def runMachineCheck():
    status = {}
    import socket, time
    machine = socket.gethostname()
    status["machine"] = machine
    this_time = time.localtime()
    time_str = time.strftime("%Y-%m-%d %H:%M:%S", this_time)
    status["time"]      = time_str
    status["year"]      = this_time.tm_year
    status["month"]     = this_time.tm_mon
    status["day"]       = this_time.tm_mday
    status["hour"]      = this_time.tm_hour
    status["minute"]    = this_time.tm_min
    status["second"]    = this_time.tm_sec
    return status

def lemmon_tools.runStatusCheck	(		MAX_ATTEMPTS = 3,
			verbose = False
	)

run LEM status check

Definition at line 23 of file lemmon_tools.py.

References runMachineCheck(), and submit_syst.str.

def runStatusCheck(MAX_ATTEMPTS=3, verbose=False):
    status = runMachineCheck()
    import urllib2
    results = {}
    for server in SERVERS:
        for port in PORTS:
            url = "http://%s:%i/status"%(server,port)
            results[url] = {"status"        :False,
                            "status_text"   :False,
                            "exception"     :False,
                            "exception_text":False}
            if verbose: print "lem  : determining status of %s"%url
            attempts = 0
            while (attempts < MAX_ATTEMPTS):
                try:
                    response = urllib2.urlopen(url)
                    content = response.read()
                    if verbose: print "lem  : ---\n%s\nlem  : ---\n"%content
                    results[url]["status"]         = "good"
                    results[url]["status_text"]    = content
                    results[url]["exception"]      = False
                    results[url]["exception_text"] = False
                    break
                except urllib2.URLError as exception:
                    attempts += 1
                    if verbose: 
                        print "lem  :     attempt[%i/%i] failed"%(attempts,MAX_ATTEMPTS)
                        print "lem  :     exception type: ",type(exception)
                        print "lem  : ---\n%s\nlem  : ---\n"%str(exception.reason)
                    results[url]["status"]         = "bad"
                    results[url]["status_text"]    = False
                    results[url]["exception"]      = str(type(exception))
                    results[url]["exception_text"] = str(exception.reason)
    status["results"] = results
    return status

Variable Documentation

lemmon_tools.PORTS = range(1024, 1032)

Definition at line 3 of file lemmon_tools.py.

list lemmon_tools.SERVERS = ["lem.hep.caltech.edu"]

Definition at line 2 of file lemmon_tools.py.

---

Generated on Fri Apr 16 2021 14:17:15 for NOvA by   1.8.11