|
|
'''
|
|
|
#!/usr/bin/python3.7.4
|
|
|
'''
|
|
|
|
|
|
|
|
|
|
|
|
from schainpy.controller import Project
|
|
|
|
|
|
import json
|
|
|
|
|
|
controller = Project()
|
|
|
controller.setup(id = '001',
|
|
|
name='Hybrid',
|
|
|
description='DP+LP')
|
|
|
|
|
|
read_unit = controller.addReadUnit(datatype='VoltageReader',
|
|
|
#path='/home/roberto/Documents/data',
|
|
|
#path='/data/DP_19_12_Campaing',
|
|
|
#######path='/home/roberto/pum',
|
|
|
path='/home/roberto/puma/2020_09/lp_faraday',
|
|
|
###path='/home/roberto/puma/2020_02/hybrid2',
|
|
|
#path='/data',
|
|
|
#path='/home/roberto/dataHybrid/hybrid',
|
|
|
##path='/home/roberto/dataHybrid',
|
|
|
#######startDate='2019/10/14',
|
|
|
startDate='2020/09/03',
|
|
|
#######endDate='2019/10/20',
|
|
|
endDate='2020/09/03',
|
|
|
#startTime='05:58:26',
|
|
|
startTime='15:00:00',
|
|
|
endTime='23:59:59',
|
|
|
online=0,
|
|
|
getByBlock='True',
|
|
|
walk=0,
|
|
|
#nTries=2,
|
|
|
#nFiles=1,
|
|
|
delay=30)
|
|
|
|
|
|
|
|
|
#############################################
|
|
|
proc_unit = controller.addProcUnit(datatype='VoltageProc',inputId=read_unit.getId())
|
|
|
op1 = proc_unit.addOperation(name='selectChannels')
|
|
|
op1.addParameter(name='channelList', value='0,1,2,3')
|
|
|
|
|
|
op121 = proc_unit.addOperation(name='ProfileSelector')
|
|
|
op121.addParameter(name='profileRangeList', value='0,149')
|
|
|
|
|
|
#op02 = proc_unit.addOperation(name='DuplicateData', optype='self')
|
|
|
|
|
|
#op002 = proc_unit.addOperation(name='filterByHeights2', optype='self')
|
|
|
#op002.addParameter(name='window', value='2', format='int')
|
|
|
|
|
|
op2 = proc_unit.addOperation(name='filterByHeights')
|
|
|
op2.addParameter(name='window', value='4')
|
|
|
|
|
|
#opp2 = proc_unit.addOperation(name='test111', optype='other')
|
|
|
|
|
|
|
|
|
op3 = proc_unit.addOperation(name='CrossProdHybrid')
|
|
|
op3.addParameter(name='NLAG', value='16')
|
|
|
op3.addParameter(name='NRANGE', value='200')
|
|
|
op3.addParameter(name='NCAL', value='0')
|
|
|
op3.addParameter(name='DPL', value='11')
|
|
|
op3.addParameter(name='NDN', value='0')
|
|
|
op3.addParameter(name='NDT', value='67')
|
|
|
op3.addParameter(name='NDP', value='67')
|
|
|
op3.addParameter(name='NSCAN', value='128')
|
|
|
op3.addParameter(name='lagind', value='(0,1,2,3,4,5,6,7,0,3,4,5,6,8,9,10)')
|
|
|
op3.addParameter(name='lagfirst', value='(1,1,1,1,1,1,1,1,0,0,0,0,0,1,1,1)')
|
|
|
op3.addParameter(name='NAVG', value='16')
|
|
|
op3.addParameter(name='nkill', value='6')
|
|
|
|
|
|
#op_LP_3 = proc_unit.addOperation(name='RemoveDebris', optype='other')
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
figpath='/home/roberto/Pictures/Test_Hybrid_2019_09_Reader+Fitter'
|
|
|
#figpath='/home/roberto/Pictures'
|
|
|
figpath='/home/roberto/Pictures/Test_Hybrid_2020_02_Reader_V2'
|
|
|
figpath='/home/roberto/Pictures/Hybrid_develop_manual'
|
|
|
|
|
|
|
|
|
op082 = proc_unit.addOperation(name='RTILPPlot')
|
|
|
op082.addParameter(name='id', value='177')
|
|
|
op082.addParameter(name='wintitle', value='RTI LP')
|
|
|
op082.addParameter(name='xmin', value='0')
|
|
|
op082.addParameter(name='xmax', value='24')
|
|
|
#op082.addParameter(name='ymin', value='180')
|
|
|
#op082.addParameter(name='ymax', value='600')
|
|
|
op082.addParameter(name='zmin', value='32')
|
|
|
op082.addParameter(name='zmax', value='80')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
op082.addParameter(name='xrange', value=str(24*1))
|
|
|
#op082.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
op080 = proc_unit.addOperation(name='CrossProductsPlot')
|
|
|
op080.addParameter(name='id', value='177')
|
|
|
op080.addParameter(name='wintitle', value='CrossProducts')
|
|
|
#op7.addParameter(name='xmin', value='0')
|
|
|
#op7.addParameter(name='xmax', value='24')
|
|
|
#op080.addParameter(name='ymin', value='180')
|
|
|
#op080.addParameter(name='ymax', value='600')
|
|
|
#op16.addParameter(name='zmin', value='32')
|
|
|
#op16.addParameter(name='zmax', value='62')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op080.addParameter(name='save', value=figpath)
|
|
|
#op080.addParameter(name='save_period', value=10)
|
|
|
|
|
|
|
|
|
|
|
|
op082 = proc_unit.addOperation(name='RTIDPPlot')
|
|
|
op082.addParameter(name='id', value='177')
|
|
|
op082.addParameter(name='wintitle', value='RTI')
|
|
|
op082.addParameter(name='xmin', value='0')
|
|
|
op082.addParameter(name='xmax', value='24')
|
|
|
#op082.addParameter(name='ymin', value='180')
|
|
|
#op082.addParameter(name='ymax', value='600')
|
|
|
op082.addParameter(name='zmin', value='32')
|
|
|
op082.addParameter(name='zmax', value='62')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
op082.addParameter(name='xrange', value=str(24*1), format='int')
|
|
|
#op082.addParameter(name='save', value=figpath, format='str')
|
|
|
|
|
|
|
|
|
|
|
|
op081 = proc_unit.addOperation(name='NoiseDPPlot')
|
|
|
op081.addParameter(name='id', value='178')
|
|
|
op081.addParameter(name='wintitle', value='Noise')
|
|
|
op081.addParameter(name='xmin', value='0')
|
|
|
op081.addParameter(name='xmax', value='24')
|
|
|
#op080.addParameter(name='ymin', value='180')
|
|
|
#op080.addParameter(name='ymax', value='600')
|
|
|
op081.addParameter(name='zmin', value='20')
|
|
|
op081.addParameter(name='zmax', value='65')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
op081.addParameter(name='xrange', value=str(24*1))
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op081.addParameter(name='save', value=figpath)
|
|
|
'''
|
|
|
|
|
|
|
|
|
'''
|
|
|
op080 = proc_unit.addOperation(name='CrossProductsLPPlot')
|
|
|
op080.addParameter(name='id', value='1777')
|
|
|
op080.addParameter(name='wintitle', value='CrossProducts')
|
|
|
#op080.addParameter(name='ymin', value='180')
|
|
|
#op080.addParameter(name='ymax', value='600')
|
|
|
#op080.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
op77_LP = proc_unit.addOperation(name='XmitWaveformPlot') #only works as it should when matplotlib.version>=3.2
|
|
|
op77_LP.addParameter(name='id', value='65')
|
|
|
op77_LP.addParameter(name='wintitle', value='Xmit Waveform')
|
|
|
#op77_LP.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
op_LP_3 = proc_unit.addOperation(name='RemoveDebris')
|
|
|
|
|
|
|
|
|
'''
|
|
|
o=proc_unit.addOperation(name='printAttribute')
|
|
|
o.addParameter(name='attributes',value='flagNoData')
|
|
|
'''
|
|
|
'''
|
|
|
dataList=['kax','kay','kbx','kby','kax2','kay2','kbx2',
|
|
|
'kby2','kaxbx','kaxby','kaybx','kayby','kaxay',
|
|
|
'kbxby','FirstAVGDate','LastAVGDate',
|
|
|
'FirstBlockDate',
|
|
|
'utctime','TimeBlockSeconds','output_LP','noise_final']
|
|
|
metadataList=['NAVG','DH','H0','DPL','NDP','NR','FirstHeight',
|
|
|
'MAXNRANGENDT','NLAG','heightList','timeZone','NRANGE','NSCAN']
|
|
|
|
|
|
|
|
|
op221 = proc_unit.addOperation(name='HDFWriter')
|
|
|
op221.addParameter(name='path', value='/home/roberto/hdf5_outputs/test')
|
|
|
op221.addParameter(name='dataList', value=dataList)
|
|
|
op221.addParameter(name='metadataList', value=metadataList)
|
|
|
op221.addParameter(name='blocksPerFile', value=1000)
|
|
|
'''
|
|
|
|
|
|
'''
|
|
|
op21 = proc_unit.addOperation(name='DatWriter_New_V1')
|
|
|
op21.addParameter(name='experiment', value='HP')
|
|
|
op21.addParameter(name='path', value='/home/roberto/DatOut_Sch/Test_Hybrid/2020_09/test_reader')
|
|
|
op21.addParameter(name='format', value='out')
|
|
|
'''
|
|
|
|
|
|
|
|
|
|
|
|
op4 = proc_unit.addOperation(name='IntegrationHP')
|
|
|
op4.addParameter(name='nint', value='2')
|
|
|
|
|
|
|
|
|
op5 = proc_unit.addOperation(name='SumFlipsHP')
|
|
|
|
|
|
op6 = proc_unit.addOperation(name='FlagBadHeights')
|
|
|
|
|
|
#op7 = proc_unit.addOperation(name='GetNoise')
|
|
|
#op7 = proc_unit.addOperation(name='NoisePower')
|
|
|
|
|
|
op8 = proc_unit.addOperation(name='DoublePulseACFs')
|
|
|
|
|
|
op9 = proc_unit.addOperation(name='FaradayAngleAndDPPower')
|
|
|
|
|
|
op10 = proc_unit.addOperation(name='IGRFModel')
|
|
|
|
|
|
op11 = proc_unit.addOperation(name='ElectronDensityFaraday')
|
|
|
op11.addParameter(name='NSHTS', value='41')
|
|
|
op11.addParameter(name='RATE', value='1.8978873e-6')
|
|
|
|
|
|
op12 = proc_unit.addOperation(name='NormalizeDPPower')
|
|
|
#op12.addParameter(name='cut0', value='170')
|
|
|
#op12.addParameter(name='cut1', value='650')
|
|
|
|
|
|
op022 = proc_unit.addOperation(name='ACFs')
|
|
|
|
|
|
op012 = proc_unit.addOperation(name='DPTemperaturesEstimation')
|
|
|
op012.addParameter(name='IBITS', value='16')
|
|
|
|
|
|
op0122 = proc_unit.addOperation(name='LongPulseAnalysis')
|
|
|
op0122.addParameter(name='NACF', value='90')
|
|
|
|
|
|
|
|
|
|
|
|
#figpath='/home/roberto/Pictures/Test_Hybrid_2020_02_V2'
|
|
|
#figpath='/home/roberto/Pictures/Test_Hybrid_2019_09_Reader+Fitter'
|
|
|
#'''
|
|
|
op026 = proc_unit.addOperation(name='ACFsPlot')
|
|
|
op026.addParameter(name='id', value='177')
|
|
|
op026.addParameter(name='wintitle', value='ACFs DP')
|
|
|
#op7.addParameter(name='xmin', value='0')
|
|
|
#op7.addParameter(name='xmax', value='24')
|
|
|
#op016.addParameter(name='ymin', value='180')
|
|
|
#op016.addParameter(name='ymax', value='600')
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op026.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
op026 = proc_unit.addOperation(name='ACFsLPPlot')
|
|
|
op026.addParameter(name='id', value='177')
|
|
|
op026.addParameter(name='wintitle', value='ACFs LP')
|
|
|
#op7.addParameter(name='xmin', value='0')
|
|
|
#op7.addParameter(name='xmax', value='24')
|
|
|
op026.addParameter(name='ymin', value='550')
|
|
|
#op026.addParameter(name='ymax', value='600')
|
|
|
#op16.addParameter(name='zmin', value='32')
|
|
|
#op16.addParameter(name='zmax', value='62')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op026.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
op026 = proc_unit.addOperation(name='EDensityHPPlot')
|
|
|
op026.addParameter(name='id', value='179')
|
|
|
op026.addParameter(name='wintitle', value='Electron Density')
|
|
|
#op7.addParameter(name='xmin', value='0')
|
|
|
#op7.addParameter(name='xmax', value='24')
|
|
|
op026.addParameter(name='ymin', value='150')
|
|
|
op026.addParameter(name='ymax', value='1350')
|
|
|
#op16.addParameter(name='zmin', value='1000')
|
|
|
#op16.addParameter(name='zmax', value='10000000')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op026.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
op0166 = proc_unit.addOperation(name='TempsHPPlot')
|
|
|
op0166.addParameter(name='id', value='1755')
|
|
|
op0166.addParameter(name='wintitle', value='Temperatures')
|
|
|
#op7.addParameter(name='xmin', value='0')
|
|
|
#op7.addParameter(name='xmax', value='24')
|
|
|
op0166.addParameter(name='ymin', value='160')
|
|
|
#op016.addParameter(name='ymax', value='600')
|
|
|
#op16.addParameter(name='zmin', value='32')
|
|
|
#op16.addParameter(name='zmax', value='62',)
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op0166.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
op0177 = proc_unit.addOperation(name='FracsHPPlot')
|
|
|
op0177.addParameter(name='id', value='1700')
|
|
|
op0177.addParameter(name='wintitle', value='Composition')
|
|
|
#op7.addParameter(name='xmin', value='0')
|
|
|
#op7.addParameter(name='xmax', value='24')
|
|
|
#op016.addParameter(name='ymin', value='180')
|
|
|
#op016.addParameter(name='ymax', value='600')
|
|
|
#op16.addParameter(name='zmin', value='32')
|
|
|
#op16.addParameter(name='zmax', value='62')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op0177.addParameter(name='save', value=figpath)
|
|
|
|
|
|
#'''
|
|
|
|
|
|
|
|
|
op018 = proc_unit.addOperation(name='DataSaveCleanerHP')
|
|
|
|
|
|
|
|
|
op181 = proc_unit.addOperation(name='ETempRTIPlot')
|
|
|
op181.addParameter(name='id', value='176')
|
|
|
op181.addParameter(name='wintitle', value='ElectronTemp')
|
|
|
op181.addParameter(name='xmin', value='0')
|
|
|
op181.addParameter(name='xmax', value='24')
|
|
|
op181.addParameter(name='ymin', value='180')
|
|
|
op181.addParameter(name='ymax', value='1350')
|
|
|
op181.addParameter(name='zmin', value='500')
|
|
|
op181.addParameter(name='zmax', value='6500')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
op181.addParameter(name='xrange', value=str(24*1))
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op181.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
op182 = proc_unit.addOperation(name='ITempRTIPlot')
|
|
|
op182.addParameter(name='id', value='176')
|
|
|
op182.addParameter(name='wintitle', value='IonTemp')
|
|
|
op182.addParameter(name='xmin', value='0')
|
|
|
op182.addParameter(name='xmax', value='24')
|
|
|
op182.addParameter(name='ymin', value='180')
|
|
|
op182.addParameter(name='ymax', value='1350')
|
|
|
op182.addParameter(name='zmin', value='500')
|
|
|
op182.addParameter(name='zmax', value='6500')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
op182.addParameter(name='xrange', value=str(24*1))
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op182.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
op183 = proc_unit.addOperation(name='HFracRTIPlot')
|
|
|
op183.addParameter(name='id', value='176')
|
|
|
op183.addParameter(name='wintitle', value='H+ Frac')
|
|
|
op183.addParameter(name='xmin', value='0')
|
|
|
op183.addParameter(name='xmax', value='24')
|
|
|
op183.addParameter(name='ymin', value='180')
|
|
|
op183.addParameter(name='ymax', value='1350')
|
|
|
op183.addParameter(name='zmin', value='0')
|
|
|
op183.addParameter(name='zmax', value='1')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
op183.addParameter(name='xrange', value=str(24*1))
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op183.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
op184 = proc_unit.addOperation(name='HeFracRTIPlot')
|
|
|
op184.addParameter(name='id', value='176')
|
|
|
op184.addParameter(name='wintitle', value='He+ Frac')
|
|
|
op184.addParameter(name='xmin', value='0')
|
|
|
op184.addParameter(name='xmax', value='24')
|
|
|
op184.addParameter(name='ymin', value='180')
|
|
|
op184.addParameter(name='ymax', value='1350')
|
|
|
op184.addParameter(name='zmin', value='0')
|
|
|
op184.addParameter(name='zmax', value='0.5')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
op184.addParameter(name='xrange', value=str(24*1))
|
|
|
#op16.addParameter(name='timerange', value=str(24*60*60))
|
|
|
#op184.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
op16 = proc_unit.addOperation(name='DenRTIPlot')
|
|
|
op16.addParameter(name='id', value='174')
|
|
|
op16.addParameter(name='wintitle', value='Electron Density RTI')
|
|
|
op16.addParameter(name='xmin', value='0')
|
|
|
op16.addParameter(name='xmax', value='24')
|
|
|
op16.addParameter(name='ymin', value='180')
|
|
|
op16.addParameter(name='ymax', value='1350')
|
|
|
op16.addParameter(name='zmin', value='1000')
|
|
|
op16.addParameter(name='zmax', value='10000000')
|
|
|
#op16.addParameter(name='showprofile', value='1')
|
|
|
|
|
|
op16.addParameter(name='xrange', value=str(24*1))
|
|
|
#op16.addParameter(name='save', value=figpath)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
'''
|
|
|
|
|
|
|
|
|
one = {'gdlatr': 'lat', 'gdlonr': 'lon'} #reader gdlatr-->lat only 1D
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
two_wr = {
|
|
|
'gdalt': 'heightList', #<----- nmonics
|
|
|
#'VIPE': ('data_output', 0),
|
|
|
# 'DVIPE': ('data_output', 1),
|
|
|
'NE': ('DensityFinal', 0),
|
|
|
'DNE': ('EDensityFinal', 0),
|
|
|
'TE': ('ElecTempFinal', 0),
|
|
|
'DTE': ('EElecTempFinal', 0),
|
|
|
'TI': ('IonTempFinal', 0),
|
|
|
'DTI': ('EIonTempFinal', 0),
|
|
|
'PH+': ('PhyFinal', 0),
|
|
|
'DPH+': ('EPhyFinal', 0),
|
|
|
'PHE+': ('PheFinal', 0),
|
|
|
'DPHE+': ('EPheFinal', 0),
|
|
|
'SRACF0': ('acfs_DP', 0),
|
|
|
'DSRACF0': ('acfs_error_DP', 0),
|
|
|
'RACF1': ('acfs_DP', 1),
|
|
|
'DRACF1': ('acfs_error_DP', 1),
|
|
|
'RACF2': ('acfs_DP', 2),
|
|
|
'DRACF2': ('acfs_error_DP', 2),
|
|
|
'RACF3': ('acfs_DP', 3),
|
|
|
'DRACF3': ('acfs_error_DP', 3),
|
|
|
'RACF4': ('acfs_DP', 4),
|
|
|
'DRACF4': ('acfs_error_DP', 4),
|
|
|
'RACF5': ('acfs_DP', 5),
|
|
|
'DRACF5': ('acfs_error_DP', 5),
|
|
|
'RACF6': ('acfs_DP', 6),
|
|
|
'DRACF6': ('acfs_error_DP', 6),
|
|
|
'RACF7': ('acfs_DP', 7),
|
|
|
'DRACF7': ('acfs_error_DP', 7),
|
|
|
'RACF8': ('acfs_DP', 8),
|
|
|
'DRACF8': ('acfs_error_DP', 8),
|
|
|
'RACF9': ('acfs_DP', 9),
|
|
|
'DRACF9': ('acfs_error_DP', 9),
|
|
|
'RACF10': ('acfs_DP', 10),
|
|
|
'DRACF10': ('acfs_error_DP', 10),
|
|
|
'RACF11': ('acfs_LP', 0),
|
|
|
'DRACF11': ('acfs_error_LP', 0),
|
|
|
'RACF12': ('acfs_LP', 1),
|
|
|
'DRACF12': ('acfs_error_LP', 1),
|
|
|
'RACF13': ('acfs_LP', 2),
|
|
|
'DRACF13': ('acfs_error_LP', 2),
|
|
|
'RACF14': ('acfs_LP', 3),
|
|
|
'DRACF14': ('acfs_error_LP', 3),
|
|
|
'RACF15': ('acfs_LP', 4),
|
|
|
'DRACF15': ('acfs_error_LP', 4),
|
|
|
'RACF16': ('acfs_LP', 5),
|
|
|
'DRACF16': ('acfs_error_LP', 5),
|
|
|
'RACF17': ('acfs_LP', 6),
|
|
|
'DRACF17': ('acfs_error_LP', 6),
|
|
|
'RACF18': ('acfs_LP', 7),
|
|
|
'DRACF18': ('acfs_error_LP', 7),
|
|
|
'RACF19': ('acfs_LP', 8),
|
|
|
'DRACF19': ('acfs_error_LP', 8),
|
|
|
'RACF20': ('acfs_LP', 9),
|
|
|
'DRACF20': ('acfs_error_LP', 9),
|
|
|
'RACF21': ('acfs_LP', 10),
|
|
|
'DRACF21': ('acfs_error_LP', 10),
|
|
|
'RACF22': ('acfs_LP', 11),
|
|
|
'DRACF22': ('acfs_error_LP', 11),
|
|
|
'RACF23': ('acfs_LP', 12),
|
|
|
'DRACF23': ('acfs_error_LP', 12),
|
|
|
'RACF24': ('acfs_LP', 13),
|
|
|
'DRACF24': ('acfs_error_LP', 13),
|
|
|
'RACF25': ('acfs_LP', 14),
|
|
|
'DRACF25': ('acfs_error_LP', 14),
|
|
|
'RACF26': ('acfs_LP', 15),
|
|
|
'DRACF26': ('acfs_error_LP', 15)
|
|
|
|
|
|
|
|
|
# 'DVIPN': ('data_output', 3),
|
|
|
#'snl': 'data_SNR'
|
|
|
} #writer
|
|
|
|
|
|
f=open('/home/roberto/moder_test.txt','r')
|
|
|
file_contents=f.read()
|
|
|
|
|
|
|
|
|
ind = ['gdalt']
|
|
|
|
|
|
meta = {
|
|
|
'kinst': 10, #instrumnet code
|
|
|
'kindat': 1802, #type of data ###to be confirmed
|
|
|
'catalog': {
|
|
|
'principleInvestigator': 'Marco Milla',
|
|
|
'expPurpose': 'Electron Density',
|
|
|
'sciRemarks': file_contents
|
|
|
},
|
|
|
'header': {
|
|
|
'analyst': 'David Hysell'
|
|
|
}
|
|
|
}
|
|
|
|
|
|
f.close()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
op_writer = proc_unit.addOperation(name='MADWriter')
|
|
|
#op_writer.addParameter(name='path', value='/home/roberto/hdf5_outputs')
|
|
|
op_writer.addParameter(name='path', value='/home/roberto/hdf5_outputs/Hybrid_2020_09_reader')
|
|
|
op_writer.addParameter(name='format', value='hdf5')
|
|
|
op_writer.addParameter(name='oneDDict', value=json.dumps(one))
|
|
|
op_writer.addParameter(name='twoDDict', value=json.dumps(two_wr))
|
|
|
op_writer.addParameter(name='ind2DList', value=json.dumps(ind))
|
|
|
op_writer.addParameter(name='metadata', value=json.dumps(meta))
|
|
|
|
|
|
#op_writer.addParameter(name='blocks', value=60)
|
|
|
'''
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
controller.start()
|
|
|
|
