Line Code
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
import FWCore.ParameterSet.Config as cms

process = cms.Process("TRANSFER")

import FWCore.Framework.test.cmsExceptionsFatal_cff
process.options = FWCore.Framework.test.cmsExceptionsFatal_cff.options

process.load("FWCore.MessageLogger.MessageLogger_cfi")

process.source = cms.Source("DQMStreamerReader",
                            SelectEvents = cms.untracked.vstring("*"),
                            runNumber =cms.untracked.uint32(1),
                            delayMillis =cms.untracked.uint32(100),
                            streamLabel = cms.untracked.string("test"),
                            runInputDir = cms.untracked.string("."),
                            datafnPosition = cms.untracked.uint32(2)
)

process.json = cms.EDAnalyzer("DQMStreamerWriteJsonAnalyzer",
                              eventsPerLumi = cms.untracked.uint32(50),
                              runNumber = cms.untracked.uint32(1),
                              streamName = cms.untracked.string("test"),
                              dataFileForEachLumi = cms.untracked.vstring(),
                              pathToWriteJson = cms.untracked.string(".")
)

process.a1 = cms.EDAnalyzer("StreamThingAnalyzer",
    product_to_get = cms.string('m1')
)

process.out = cms.OutputModule("PoolOutputModule",
    fileName = cms.untracked.string('myout.root')
)

process.end = cms.EndPath(process.a1*process.out*process.json)