15 payloadDir =
"./archive_repro_13May/payloads/" 16 aCommand =
"ls " + payloadDir +
" | grep BeamSpotObjects_2009_LumiBased_ | grep txt" 17 output = subprocess.getstatusoutput( aCommand )
18 listOfFiles = output[1].
split(
'\n')
21 for fileName
in listOfFiles:
22 file = open(payloadDir + fileName)
24 if line.find(
"since") != -1:
26 tmpObj.run =
unpackLumiid(long(line.split(
' ')[1]))[
"run"]
27 tmpObj.iovSince = line.split(
' ')[1].
replace(
'\n',
'')
28 tmpObj.fileName = fileName
29 finalList[tmpObj.run] = tmpObj
33 sortedKeys = sorted(finalList.keys())
36 regExp = re.search(
'(\D+)(\d+)_(\d+)_(\w+)',listOfFiles[0])
38 databaseTag = regExp.group(4)
40 exit(
"Can't find reg exp")
42 uuid = subprocess.getstatusoutput(
'uuidgen -t')[1]
43 final_sqlite_file_name = databaseTag +
'@' + uuid
44 megaNumber =
"18446744073709551615" 45 print(final_sqlite_file_name)
46 for run
in sortedKeys:
47 appendSqliteFile(final_sqlite_file_name +
".db", payloadDir+finalList[run].fileName.replace(
".txt",
".db"), databaseTag, finalList[run].iovSince, megaNumber,payloadDir)
48 print(finalList[run].fileName.replace(
".txt",
".db"))
49 aCommand =
"cp " + payloadDir + finalList[sortedKeys[0]].fileName +
" " + payloadDir + final_sqlite_file_name +
".txt" 50 output = subprocess.getstatusoutput( aCommand )
53 print(finalList[sortedKeys[0]].fileName)
def replace(string, replacements)
def appendSqliteFile(combinedSqliteFileName, sqliteFileName, tagName, IOVSince, IOVTill, tmpDir="/tmp/")
void print(TMatrixD &m, const char *label=nullptr, bool mathematicaFormat=false)
def split(sequence, size)