Reference Manual

Functions
def	convert_time

def	extract_value

def	get_data

def	get_value

def	size_format

Function Documentation

def cmssw_das_client.convert_time ( val )

Definition at line 9 of file cmssw_das_client.py.

Referenced by extract_value().

 
 def convert_time(val):
     "Convert given timestamp into human readable format"
     if  isinstance(val, int) or isinstance(val, float):
         return time.strftime('%d/%b/%Y_%H:%M:%S_GMT', time.gmtime(val))
     return val

cmssw_das_client.convert_time

def convert_time

Definition: cmssw_das_client.py:9

def cmssw_das_client.extract_value	(	row,
		key,
		base = `10`
	)

Generator which extracts row[key] value

Definition at line 36 of file cmssw_das_client.py.

References convert_time(), and size_format().

Referenced by get_value().

 
 def extract_value(row, key, base=10):
     """Generator which extracts row[key] value"""
     if  isinstance(row, dict) and key in row:
         if  key == 'creation_time':
             row = convert_time(row[key])
         elif  key == 'size':
             row = size_format(row[key], base)
         else:
             row = row[key]
         yield row
     if  isinstance(row, list) or isinstance(row, GeneratorType):
         for item in row:
             for vvv in extract_value(item, key, base):
                 yield vvv

cmssw_das_client.size_format

def size_format

Definition: cmssw_das_client.py:15

cmssw_das_client.extract_value

def extract_value

Definition: cmssw_das_client.py:36

cmssw_das_client.convert_time

def convert_time

Definition: cmssw_das_client.py:9

def cmssw_das_client.get_data	(	query,
		limit = `None`,
		threshold = `None`,
		idx = `None`,
		host = `None`,
		cmd = `None`
	)

Definition at line 70 of file cmssw_das_client.py.

References submitPVValidationJobs.split().

Referenced by shallowTree_test_template.add_rawRelVals(), and tkal_create_file_lists.das_client().

 
 def get_data(query, limit=None, threshold=None, idx=None, host=None, cmd=None):
   cmd_opts = "--format=json"
   if threshold is not None: cmd_opts += " --threshold=%s" % threshold
   if limit     is not None: cmd_opts += " --limit=%s"     % limit
   if idx       is not None: cmd_opts += " --idx=%s"       % idx
   if host      is not None: cmd_opts += " --host=%s"      % host
   if not cmd:
     cmd = "das_client"
     for path in os.getenv('PATH').split(':'):
       if  os.path.isfile(os.path.join(path, 'dasgoclient')):
         cmd = "dasgoclient"
         break
 
   p = subprocess.Popen("%s %s --query '%s'" % (cmd, cmd_opts, query),shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
   stdout, stderr = p.communicate()
   if not p.returncode: return loads(stdout)
   return {'status' : 'error', 'reason' : stdout}

def cmssw_das_client.get_value	(	data,
		filters,
		base = `10`
	)

Filter data from a row for given list of filters

Definition at line 51 of file cmssw_das_client.py.

References extract_value().

 
 def get_value(data, filters, base=10):
   """Filter data from a row for given list of filters"""
   for ftr in filters:
     if  ftr.find('>') != -1 or ftr.find('<') != -1 or ftr.find('=') != -1:
       continue
     row = dict(data)
     values = []
     keys = ftr.split('.')
     for key in keys:
       val = [v for v in extract_value(row, key, base)]
       if  key == keys[-1]: # we collect all values at last key
         values += [dumps(i) for i in val]
       else:
         row = val
       if  len(values) == 1:
         yield values[0]
       else:
         yield values

cmssw_das_client.get_value

def get_value

Definition: cmssw_das_client.py:51