14 payloadDir =
"./archive_repro_13May/payloads/" 15 aCommand =
"ls " + payloadDir +
" | grep BeamSpotObjects_2009_LumiBased_ | grep txt" 16 output = commands.getstatusoutput( aCommand )
17 listOfFiles = output[1].
split(
'\n')
20 for fileName
in listOfFiles:
21 file = open(payloadDir + fileName)
23 if line.find(
"since") != -1:
25 tmpObj.run =
unpackLumiid(long(line.split(
' ')[1]))[
"run"]
26 tmpObj.iovSince = line.split(
' ')[1].
replace(
'\n',
'')
27 tmpObj.fileName = fileName
28 finalList[tmpObj.run] = tmpObj
32 sortedKeys = 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 = commands.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 = commands.getstatusoutput( aCommand )
53 print finalList[sortedKeys[0]].fileName
def replace(string, replacements)
def appendSqliteFile(combinedSqliteFileName, sqliteFileName, tagName, IOVSince, IOVTill, tmpDir="/tmp/")