schain Files · schainpy/scripts/PPD.py

Fix all PlotData, add SpectraMean, CrossSpectra plots, now Parameters extends Spectra fix bugs in ParametersProc

José Chávez - - Load All Authors

File last commit:

r913:66816cdd4da4


                r922:d680543828ae

Download file

             PPD.py
        
                    87 lines
            
             | 4.0 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / schainpy / scripts / PPD.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        jespinoza
    
add multiSchain (@jchavez)

              r892
            
      import argparse

      from schainpy.controller import Project, multiSchain

      desc = "HF_EXAMPLE"

      def fiber(cursor, skip, q, dt):

          controllerObj = Project()

          controllerObj.setup(id='191', name='test01', description=desc)

          readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',

        José Chávez
    
funcionando todo

              r898
            
                                                       path='/home/nanosat/data/hysell_data20/pdata',

        jespinoza
    
add multiSchain (@jchavez)

              r892
            
                                                       startDate=dt,

                                                       endDate=dt,

                                                       startTime="00:00:00",

                                                       endTime="23:59:59",

                                                       online=0,

                                                       #set=1426485881,

                                                       delay=10,

                                                       walk=1,

                                                       queue=q,

                                                       cursor=cursor,

                                                       skip=skip,

                                                       #timezone=-5*3600

                                                       )

          #     #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')

          #

          procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())

          # opObj11 = procUnitConfObj2.addParameter(name='pairsList', value='(0,1)', format='pairslist')

          #

        José Chávez
    
funcionando en mi compu

              r900
            
          # procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())

          # opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')

        jespinoza
    
add multiSchain (@jchavez)

              r892
            
          #

          #     opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')

          #     opObj11.addParameter(name='id', value='1000', format='int')

          #     opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str')

          #     opObj11.addParameter(name='channelList', value='0', format='intlist')

          #     opObj11.addParameter(name='zmin', value='-120', format='float')

          #     opObj11.addParameter(name='zmax', value='-70', format='float')

          #     opObj11.addParameter(name='save', value='1', format='int')

          #     opObj11.addParameter(name='figpath', value=figpath, format='str')

        José Chávez
    
funcionando todo

              r898
            
          # opObj11 = procUnitConfObj2.addOperation(name='RTIPlot', optype='other')

          # opObj11.addParameter(name='id', value='2000', format='int')

          # opObj11.addParameter(name='wintitzmaxle', value='HF_Jicamarca', format='str')

          # opObj11.addParameter(name='showprofile', value='0', format='int')

          # # opObj11.addParameter(name='channelList', value='0', format='intlist')

          # #     opObj11.addParameter(name='xmin', value='0', format='float')

          # opObj11.addParameter(name='xmin', value='0', format='float')

          # opObj11.addParameter(name='xmax', value='24', format='float')

        José Chávez
    
cambiados los kwargs para cada operacion/unidad de procesamiento

              r897
            
        jespinoza
    
add multiSchain (@jchavez)

              r892
            
          # opObj11.addParameter(name='zmin', value='-110', format='float')

          # opObj11.addParameter(name='zmax', value='-70', format='float')

          # opObj11.addParameter(name='save', value='0', format='int')

        José Chávez
    
cambiados los kwargs para cada operacion/unidad de procesamiento

              r897
            
          # # opObj11.addParameter(name='figpath', value='/tmp/', format='str')

          #

        jespinoza
    
add multiSchain (@jchavez)

              r892
            
          opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other')

          opObj12.addParameter(name='zeromq', value=1, format='int')

        José Chávez
    
nada

              r913
            
        José Chávez
    
funcionando en mi compu

              r900
            
          # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')

          # opObj13.addParameter(name='zeromq', value=1, format='int')

          # opObj13.addParameter(name='server', value="juanca", format='str')

        José Chávez
    
funcionando todo

              r898
            
        José Chávez
    
receiver data modificado para web

              r904
            
          opObj12.addParameter(name='delay', value=1, format='int')

        José Chávez
    
funcionando todo

              r898
            
        jespinoza
    
add multiSchain (@jchavez)

              r892
            
          # print "Escribiendo el archivo XML"

          # controllerObj.writeXml(filename)

          # print "Leyendo el archivo XML"

          # controllerObj.readXml(filename)

          # timeit.timeit('controllerObj.run()', number=2)

        José Chávez
    
funcionando todo

              r898
            
          controllerObj.start()

        jespinoza
    
add multiSchain (@jchavez)

              r892
            
      if __name__ == '__main__':

          parser = argparse.ArgumentParser(description='Set number of parallel processes')

        José Chávez
    
receiver data modificado para web

              r904
            
          parser.add_argument('--nProcess', default=1, type=int)

        jespinoza
    
add multiSchain (@jchavez)

              r892
            
          args = parser.parse_args()

        José Chávez
    
funcionando todo

              r898
            
          multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26')

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

jespinoza add multiSchain (@jchavez)	r892	import argparse

		from schainpy.controller import Project, multiSchain

		desc = "HF_EXAMPLE"

		def fiber(cursor, skip, q, dt):

		controllerObj = Project()

		controllerObj.setup(id='191', name='test01', description=desc)

		readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
José Chávez funcionando todo	r898	path='/home/nanosat/data/hysell_data20/pdata',
jespinoza add multiSchain (@jchavez)	r892	startDate=dt,
		endDate=dt,
		startTime="00:00:00",
		endTime="23:59:59",
		online=0,
		#set=1426485881,
		delay=10,
		walk=1,
		queue=q,
		cursor=cursor,
		skip=skip,
		#timezone=-5*3600
		)

		# #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
		#
		procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
		# opObj11 = procUnitConfObj2.addParameter(name='pairsList', value='(0,1)', format='pairslist')
		#
José Chávez funcionando en mi compu	r900	# procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
		# opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
jespinoza add multiSchain (@jchavez)	r892
		#
		# opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
		# opObj11.addParameter(name='id', value='1000', format='int')
		# opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str')
		# opObj11.addParameter(name='channelList', value='0', format='intlist')
		# opObj11.addParameter(name='zmin', value='-120', format='float')
		# opObj11.addParameter(name='zmax', value='-70', format='float')
		# opObj11.addParameter(name='save', value='1', format='int')
		# opObj11.addParameter(name='figpath', value=figpath, format='str')

José Chávez funcionando todo	r898	# opObj11 = procUnitConfObj2.addOperation(name='RTIPlot', optype='other')
		# opObj11.addParameter(name='id', value='2000', format='int')
		# opObj11.addParameter(name='wintitzmaxle', value='HF_Jicamarca', format='str')
		# opObj11.addParameter(name='showprofile', value='0', format='int')
		# # opObj11.addParameter(name='channelList', value='0', format='intlist')
		# # opObj11.addParameter(name='xmin', value='0', format='float')
		# opObj11.addParameter(name='xmin', value='0', format='float')
		# opObj11.addParameter(name='xmax', value='24', format='float')
José Chávez cambiados los kwargs para cada operacion/unidad de procesamiento	r897
jespinoza add multiSchain (@jchavez)	r892	# opObj11.addParameter(name='zmin', value='-110', format='float')
		# opObj11.addParameter(name='zmax', value='-70', format='float')
		# opObj11.addParameter(name='save', value='0', format='int')
José Chávez cambiados los kwargs para cada operacion/unidad de procesamiento	r897	# # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
		#
jespinoza add multiSchain (@jchavez)	r892	opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other')
		opObj12.addParameter(name='zeromq', value=1, format='int')

José Chávez nada	r913
José Chávez funcionando en mi compu	r900	# opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
		# opObj13.addParameter(name='zeromq', value=1, format='int')
		# opObj13.addParameter(name='server', value="juanca", format='str')
José Chávez funcionando todo	r898
José Chávez receiver data modificado para web	r904	opObj12.addParameter(name='delay', value=1, format='int')
José Chávez funcionando todo	r898

jespinoza add multiSchain (@jchavez)	r892	# print "Escribiendo el archivo XML"
		# controllerObj.writeXml(filename)
		# print "Leyendo el archivo XML"
		# controllerObj.readXml(filename)


		# timeit.timeit('controllerObj.run()', number=2)

José Chávez funcionando todo	r898	controllerObj.start()
jespinoza add multiSchain (@jchavez)	r892

		if __name__ == '__main__':
		parser = argparse.ArgumentParser(description='Set number of parallel processes')
José Chávez receiver data modificado para web	r904	parser.add_argument('--nProcess', default=1, type=int)
jespinoza add multiSchain (@jchavez)	r892	args = parser.parse_args()
José Chávez funcionando todo	r898	multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26')