|
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
|
#
# provide online L1 Trigger DQM input from file(s)
#
# V M Ghete 2010-07-09
import FWCore.ParameterSet.Config as cms
###################### user choices ######################
# choose one sample identifier from the list of data samples
#
sampleIdentifier = '165633-CAFDQM'
#sampleIdentifier = '195378'
maxNumberEvents = 5000
###################### end user choices ###################
# initialize list of files, of secondary files, list of selected events and luminosity segments
readFiles = cms.untracked.vstring()
secFiles = cms.untracked.vstring()
selectedEvents = cms.untracked.VEventRange()
selectedLumis= cms.untracked.VLuminosityBlockRange()
maxEvents = cms.untracked.PSet(
input = cms.untracked.int32(maxNumberEvents)
)
if sampleIdentifier == '195378' :
runNumber = '195378'
dataset = '/MinimumBias/Run2012B-v1/RAW'
dataType = 'RAW'
useDAS = True
selectedLumis= cms.untracked.VLuminosityBlockRange(
'195378:1275-195378:max'
)
elif sampleIdentifier == '195379' :
runNumber = '195379'
dataset = '/MinimumBias/Run2012B-v1/RAW'
dataType = 'RAW'
useDAS = True
elif sampleIdentifier == '195390' :
runNumber = '195390'
dataset = '/MinimumBias/Run2012B-v1/RAW'
dataType = 'RAW'
useDAS = True
# high PU run 2011
elif sampleIdentifier == '179828' :
runNumber = '179828'
dataset = '/ZeroBiasHPF0/Run2011B-v1/RAW'
dataType = 'RAW'
useDAS = True
elif sampleIdentifier == '165633-CAFDQM' :
runNumber = '165633'
dataset = '/ZeroBiasHPF0/Run2011B-v1/RAW'
dataType = 'RAW'
useDAS = False
readFiles.extend( [
'file:/afs/cern.ch/cms/CAF/CMSCOMM/COMM_DQM/DQMTest/MinimumBias__RAW__v1__165633__1CC420EE-B686-E011-A788-0030487CD6E8.root'
]);
elif sampleIdentifier == 'FileStream_105760' :
runNumber = '105760'
dataset = 'A_Stream'
dataType = 'FileStream'
useDAS = False
readFiles.extend( [
'file:/lookarea_SM/MWGR_29.00105760.0001.A.storageManager.00.0000.dat'
] );
else :
print('Error: sample identifier ', sampleIdentifier, ' not defined.\n')
errorUserOptions = True
runNumber = '0'
dataset = 'None'
dataType = 'None'
useDAS = False
#
# end of data samples
#
print(" Run number: ", runNumber)
print(" Dataset: ", dataset)
print(" Data type: ", dataType)
if useDAS :
import das_client
import os
# query DAS
myQuery = 'file dataset=' + dataset + ' run=' + runNumber
dasClientCommand = 'das_client.py --limit=0 --format=plain --query='+'"'+myQuery+'"'
data = os.popen(dasClientCommand)
filePaths = data.readlines()
print('\n das_client using the query')
print(' ', myQuery)
print(' retrieved the following files\n')
for line in filePaths :
print(' ', line)
readFiles.extend(filePaths);
# nothing added to secondary files by DAS
secFiles.extend([
])
# for RAW data, run first the RAWTODIGI
if dataType == 'StreamFile' :
source = cms.Source("NewEventStreamFileReader", fileNames=readFiles)
else :
source = cms.Source ('PoolSource',
fileNames=readFiles,
secondaryFileNames=secFiles,
lumisToProcess = selectedLumis,
eventsToProcess = selectedEvents
)
|