##// END OF EJS Templates
schain
RSS
Update version, fix kwargs for self operations (methods), Add SendToWeb...
Update version, fix kwargs for self operations (methods), Add SendToWeb operation to publish plots arguments
José Chávez - - Load All Authors

File last commit:

r897:bf36fab25ada
r906:a52f011a763e
Show More
julia_mp.py
75 lines | 3.0 KiB | text/x-python | PythonLexer
/ schainpy / scripts / julia_mp.py
History | Source | Raw |Copy content |Copy permalink
Juan C. Valdez
test script using MP
 r867 #!/usr/bin/env python
'''
Created on Jul 7, 2014
@author: roj-idl71
'''
import os, sys
from datetime import datetime, timedelta
import multiprocessing
from schainpy.controller import Project
def main(date):
controllerObj = Project()
José Chávez
cambios de prueba
 r890 controllerObj.setup(id='191', name='test01', description='')
Juan C. Valdez
test script using MP
 r867
readUnitConfObj = controllerObj.addReadUnit(datatype='Spectra',
José Chávez
cambios de prueba
 r890 path='/home/nanosat/data/zeus',
Juan C. Valdez
test script using MP
 r867 startDate=date,
endDate=date,
startTime='00:00:00',
endTime='23:59:59',
online=0,
walk=1,
expLabel='')
procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
#opObj11 = procUnitConfObj1.addOperation(name='removeDC')
#opObj11.addParameter(name='mode', value='1', format='int')
#opObj11 = procUnitConfObj1.addOperation(name='removeInterference')
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897 opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other')
opObj11.addParameter(name='id', value='10', format='int')
Juan C. Valdez
test script using MP
 r867 opObj11.addParameter(name='wintitle', value='150Km', format='str')
opObj11.addParameter(name='colormap', value='jro', format='str')
opObj11.addParameter(name='xaxis', value='time', format='str')
opObj11.addParameter(name='xmin', value='0', format='int')
opObj11.addParameter(name='xmax', value='23', format='int')
#opObj11.addParameter(name='ymin', value='100', format='int')
#opObj11.addParameter(name='ymax', value='150', format='int')
opObj11.addParameter(name='zmin', value='10', format='int')
opObj11.addParameter(name='zmax', value='35', format='int')
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
opObject12 = procUnitConfObj1.addOperation(name='PlotRTIData', optype='other')
opObject12.addParameter(name='id', value='12', format='int')
opObject12.addParameter(name='wintitle', value='150Km', format='str')
opObject12.addParameter(name='colormap', value='jro', format='str')
opObject12.addParameter(name='xaxis', value='time', format='str')
opObject12.addParameter(name='xmin', value='0', format='int')
opObject12.addParameter(name='xmax', value='23', format='int')
#opObject12.addParameter(name='ymin', value='100', format='int')
#opObject12.addParameter(name='ymax', value='150', format='int')
opObject12.addParameter(name='zmin', value='10', format='int')
opObject12.addParameter(name='zmax', value='35', format='int')
#opObject12.addParameter(name='pause', value='1', format='bool')
opObject12.addParameter(name='show', value='0', format='bool')
opObject12.addParameter(name='save', value='/tmp', format='str')
Juan C. Valdez
test script using MP
 r867
controllerObj.start()
if __name__=='__main__':
José Chávez
cambios de prueba
 r890
Juan C. Valdez
test script using MP
 r867 dt = datetime(2017, 1, 12)
José Chávez
cambios de prueba
 r890
dates = [(dt+timedelta(x)).strftime('%Y/%m/%d') for x in range(20)]
Juan C. Valdez
test script using MP
 r867 p = multiprocessing.Pool(4)
p.map(main, dates)