From 9e80eea2eb45d9cb9c03d238f4f4a16b2207995e 2017-05-11 13:34:03 From: Juan C. Espinoza Date: 2017-05-11 13:34:03 Subject: [PATCH] fixing merge --- diff --git a/schainpy/controller.py b/schainpy/controller.py index 51b03e9..200da90 100644 --- a/schainpy/controller.py +++ b/schainpy/controller.py @@ -8,6 +8,7 @@ import ast import datetime import traceback import math +import time from multiprocessing import Process, Queue, cpu_count import schainpy @@ -66,8 +67,7 @@ def multiSchain(child, nProcess=cpu_count(), startDate=None, endDate=None, by_da for process in processes: process.join() process.terminate() - sys.exit() - + time.sleep(3) class ParameterConf(): diff --git a/schainpy/model/data/jrodata.py b/schainpy/model/data/jrodata.py index 164984d..2f06d06 100644 --- a/schainpy/model/data/jrodata.py +++ b/schainpy/model/data/jrodata.py @@ -65,7 +65,7 @@ def hildebrand_sekhon(data, navg): anoise : noise's level """ - sortdata = numpy.sort(data,axis=None) + sortdata = numpy.sort(data, axis=None) # lenOfData = len(sortdata) # nums_min = lenOfData*0.2 # diff --git a/schainpy/model/graphics/jroplot_data.py b/schainpy/model/graphics/jroplot_data.py index b9661b3..6ffd6fc 100644 --- a/schainpy/model/graphics/jroplot_data.py +++ b/schainpy/model/graphics/jroplot_data.py @@ -24,9 +24,8 @@ class PlotData(Operation, Process): CODE = 'Figure' colormap = 'jro' - CONFLATE = True + CONFLATE = False __MAXNUMX = 80 - __MAXNUMY = 80 __missing = 1E30 def __init__(self, **kwargs): @@ -55,7 +54,9 @@ class PlotData(Operation, Process): self.xrange = kwargs.get('xrange', 24) self.ymin = kwargs.get('ymin', None) self.ymax = kwargs.get('ymax', None) + self.__MAXNUMY = kwargs.get('decimation', 80) self.throttle_value = 5 + self.times = [] def fill_gaps(self, x_buffer, y_buffer, z_buffer): @@ -120,15 +121,23 @@ class PlotData(Operation, Process): receiver = context.socket(zmq.SUB) receiver.setsockopt(zmq.SUBSCRIBE, '') receiver.setsockopt(zmq.CONFLATE, self.CONFLATE) + if 'server' in self.kwargs['parent']: receiver.connect('ipc:///tmp/{}.plots'.format(self.kwargs['parent']['server'])) else: receiver.connect("ipc:///tmp/zmq.plots") + seconds_passed = 0 + while True: try: - self.data = receiver.recv_pyobj(flags=zmq.NOBLOCK) + self.data = receiver.recv_pyobj(flags=zmq.NOBLOCK)#flags=zmq.NOBLOCK + self.started = self.data['STARTED'] self.dataOut = self.data['dataOut'] + + if (len(self.times) < len(self.data['times']) and not self.started and self.data['ENDED']): + continue + self.times = self.data['times'] self.times.sort() self.throttle_value = self.data['throttle'] @@ -136,16 +145,25 @@ class PlotData(Operation, Process): self.max_time = self.times[-1] if self.isConfig is False: + print 'setting up' self.setup() self.isConfig = True - self.__plot() + self.__plot() if self.data['ENDED'] is True: + print '********GRAPHIC ENDED********' + self.ended = True self.isConfig = False + self.__plot() + elif seconds_passed >= self.data['throttle']: + print 'passed', seconds_passed + self.__plot() + seconds_passed = 0 except zmq.Again as e: print 'Waiting for data...' - plt.pause(self.throttle_value) + plt.pause(2) + seconds_passed += 2 def close(self): if self.dataOut: @@ -472,15 +490,14 @@ class PlotRTIData(PlotData): self.z = np.array(self.z) for n, ax in enumerate(self.axes): - x, y, z = self.fill_gaps(*self.decimate()) xmin = self.min_time xmax = xmin+self.xrange*60*60 + self.zmin = self.zmin if self.zmin else np.min(self.z) + self.zmax = self.zmax if self.zmax else np.max(self.z) if ax.firsttime: self.ymin = self.ymin if self.ymin else np.nanmin(self.y) self.ymax = self.ymax if self.ymax else np.nanmax(self.y) - self.zmin = self.zmin if self.zmin else np.nanmin(self.z) - self.zmax = self.zmax if self.zmax else np.nanmax(self.z) plot = ax.pcolormesh(x, y, z[n].T, vmin=self.zmin, vmax=self.zmax, diff --git a/schainpy/model/graphics/jroplot_parameters.py b/schainpy/model/graphics/jroplot_parameters.py index eb87882..dd1dbb1 100644 --- a/schainpy/model/graphics/jroplot_parameters.py +++ b/schainpy/model/graphics/jroplot_parameters.py @@ -1,7 +1,7 @@ import os import datetime import numpy - +import inspect from figure import Figure, isRealtime, isTimeInHourRange from plotting_codes import * @@ -642,7 +642,6 @@ class ParametersPlot(Figure): save=False, figpath='./', lastone=0,figfile=None, ftp=False, wr_period=1, show=True, server=None, folder=None, username=None, password=None, ftp_wei=0, exp_code=0, sub_exp_code=0, plot_pos=0): - """ Input: @@ -792,7 +791,7 @@ class Parameters1Plot(Figure): self.__nsubplots = 1 self.WIDTH = 800 - self.HEIGHT = 150 + self.HEIGHT = 180 self.WIDTHPROF = 120 self.HEIGHTPROF = 0 self.counter_imagwr = 0 @@ -857,7 +856,7 @@ class Parameters1Plot(Figure): save=False, figpath='./', lastone=0,figfile=None, ftp=False, wr_period=1, show=True, server=None, folder=None, username=None, password=None, ftp_wei=0, exp_code=0, sub_exp_code=0, plot_pos=0): - + #print inspect.getargspec(self.run).args """ Input: diff --git a/schainpy/model/io/jroIO_base.py b/schainpy/model/io/jroIO_base.py index c753eb3..a9b38a1 100644 --- a/schainpy/model/io/jroIO_base.py +++ b/schainpy/model/io/jroIO_base.py @@ -888,7 +888,8 @@ class JRODataReader(JRODataIO): print '[Reading] No more files to read' return 0 - print '[Reading] Setting the file: %s' % self.filename + if self.verbose: + print '[Reading] Setting the file: %s' % self.filename self.__readFirstHeader() self.nReadBlocks = 0 @@ -1053,9 +1054,10 @@ class JRODataReader(JRODataIO): break - print "[Reading] Block No. %d/%d -> %s" %(self.nReadBlocks, - self.processingHeaderObj.dataBlocksPerFile, - self.dataOut.datatime.ctime()) + if self.verbose: + print "[Reading] Block No. %d/%d -> %s" %(self.nReadBlocks, + self.processingHeaderObj.dataBlocksPerFile, + self.dataOut.datatime.ctime()) return 1 def __readFirstHeader(self): @@ -1266,7 +1268,9 @@ class JRODataReader(JRODataIO): blocktime=None, queue=None, skip=None, - cursor=None): + cursor=None, + warnings=True, + verbose=True): if path == None: raise ValueError, "[Reading] The path is not valid" @@ -1338,6 +1342,9 @@ class JRODataReader(JRODataIO): self.selBlocksize = blocksize self.selBlocktime = blocktime + # Verbose----------- + self.verbose = verbose + self.warnings = warnings if not(self.setNextFile()): if (startDate!=None) and (endDate!=None): diff --git a/schainpy/model/proc/jroproc_base.py b/schainpy/model/proc/jroproc_base.py index 6ec501c..55f3afd 100644 --- a/schainpy/model/proc/jroproc_base.py +++ b/schainpy/model/proc/jroproc_base.py @@ -3,6 +3,29 @@ $Author: murco $ $Id: jroproc_base.py 1 2012-11-12 18:56:07Z murco $ ''' +import inspect +from fuzzywuzzy import process + +def checkKwargs(method, kwargs): + currentKwargs = kwargs + choices = inspect.getargspec(method).args + try: + choices.remove('self') + except Exception as e: + pass + + try: + choices.remove('dataOut') + except Exception as e: + pass + + for kwarg in kwargs: + fuzz = process.extractOne(kwarg, choices) + if fuzz is None: + continue + if fuzz[1] < 100: + raise Exception('\x1b[0;32;40mDid you mean {} instead of {} in {}? \x1b[0m'. + format(fuzz[0], kwarg, method.__self__.__class__.__name__)) class ProcessingUnit(object): @@ -41,14 +64,18 @@ class ProcessingUnit(object): self.args = args self.kwargs = kwargs + checkKwargs(self.run, kwargs) + + def getAllowedArgs(self): + return inspect.getargspec(self.run).args def addOperationKwargs(self, objId, **kwargs): ''' ''' - + self.operationKwargs[objId] = kwargs - - + + def addOperation(self, opObj, objId): """ @@ -117,17 +144,17 @@ class ProcessingUnit(object): #Executing the self method if hasattr(self, 'mp'): - if name=='run': - if self.mp is False: + if name=='run': + if self.mp is False: self.mp = True self.start() else: self.operationKwargs[opId]['parent'] = self.kwargs - methodToCall(**self.operationKwargs[opId]) + methodToCall(**self.operationKwargs[opId]) else: - if name=='run': + if name=='run': methodToCall(**self.kwargs) - else: + else: methodToCall(**self.operationKwargs[opId]) if self.dataOut is None: @@ -168,7 +195,7 @@ class ProcessingUnit(object): else: externalProcObj.run(self.dataOut, **externalProcObj.kwargs) self.operationKwargs[objId] = externalProcObj.kwargs - + return True @@ -283,6 +310,10 @@ class Operation(object): self.__buffer = None self.isConfig = False self.kwargs = kwargs + checkKwargs(self.run, kwargs) + + def getAllowedArgs(self): + return inspect.getargspec(self.run).args def setup(self): diff --git a/schainpy/model/utils/jroutils_publish.py b/schainpy/model/utils/jroutils_publish.py index f33d6f9..1deba7a 100644 --- a/schainpy/model/utils/jroutils_publish.py +++ b/schainpy/model/utils/jroutils_publish.py @@ -7,7 +7,7 @@ import json import numpy import paho.mqtt.client as mqtt import zmq -import cPickle as pickle +from profilehooks import profile import datetime from zmq.utils.monitor import recv_monitor_message from functools import wraps @@ -29,7 +29,7 @@ def roundFloats(obj): elif isinstance(obj, float): return round(obj, 2) -def decimate(z): +def decimate(z, MAXNUMY): # dx = int(len(self.x)/self.__MAXNUMX) + 1 dy = int(len(z[0])/MAXNUMY) + 1 @@ -107,7 +107,7 @@ class PublishData(Operation): print "MQTT Conection error." self.client = False - def setup(self, port=1883, username=None, password=None, clientId="user", zeromq=1, **kwargs): + def setup(self, port=1883, username=None, password=None, clientId="user", zeromq=1, verbose=True, **kwargs): self.counter = 0 self.topic = kwargs.get('topic', 'schain') self.delay = kwargs.get('delay', 0) @@ -119,6 +119,8 @@ class PublishData(Operation): self.zeromq = zeromq self.mqtt = kwargs.get('plottype', 0) self.client = None + self.verbose = verbose + self.dataOut.firstdata = True setup = [] if mqtt is 1: self.client = mqtt.Client( @@ -150,6 +152,7 @@ class PublishData(Operation): self.zmq_socket.connect(address) time.sleep(1) + def publish_data(self): self.dataOut.finished = False if self.mqtt is 1: @@ -230,8 +233,11 @@ class PublishData(Operation): self.client.publish(self.topic + self.plottype, json.dumps(payload), qos=0) if self.zeromq is 1: - print '[Sending] {} - {}'.format(self.dataOut.type, self.dataOut.datatime) + if self.verbose: + print '[Sending] {} - {}'.format(self.dataOut.type, self.dataOut.datatime) self.zmq_socket.send_pyobj(self.dataOut) + self.dataOut.firstdata = False + def run(self, dataOut, **kwargs): self.dataOut = dataOut @@ -246,12 +252,11 @@ class PublishData(Operation): if self.zeromq is 1: self.dataOut.finished = True self.zmq_socket.send_pyobj(self.dataOut) - + self.zmq_socket.close() if self.client: self.client.loop_stop() self.client.disconnect() - class ReceiverData(ProcessingUnit, Process): throttle_value = 5 @@ -330,12 +335,13 @@ class ReceiverData(ProcessingUnit, Process): return sendDataThrottled + def send(self, data): # print '[sending] data=%s size=%s' % (data.keys(), len(data['times'])) self.sender.send_pyobj(data) - def update(self): + def update(self): t = self.dataOut.utctime if t in self.data['times']: @@ -398,11 +404,14 @@ class ReceiverData(ProcessingUnit, Process): self.sender_web = self.context.socket(zmq.PUB) self.sender_web.connect(self.plot_address) time.sleep(1) + if 'server' in self.kwargs: self.sender.bind("ipc:///tmp/{}.plots".format(self.kwargs['server'])) else: self.sender.bind("ipc:///tmp/zmq.plots") + time.sleep(3) + t = Thread(target=self.event_monitor, args=(monitor,)) t.start() @@ -413,6 +422,10 @@ class ReceiverData(ProcessingUnit, Process): self.update() + if self.dataOut.firstdata is True: + self.data['STARTED'] = True + + if self.dataOut.finished is True: self.send(self.data) self.connections -= 1 @@ -421,6 +434,7 @@ class ReceiverData(ProcessingUnit, Process): self.data['ENDED'] = True self.send(self.data) self.setup() + self.started = False else: if self.realtime: self.send(self.data) @@ -429,6 +443,7 @@ class ReceiverData(ProcessingUnit, Process): self.sendData(self.send, self.data) self.started = True + self.data['STARTED'] = False return def sendToWeb(self): diff --git a/schainpy/scripts/PPD.py b/schainpy/scripts/PPD.py index f9f46d4..ceca5ad 100644 --- a/schainpy/scripts/PPD.py +++ b/schainpy/scripts/PPD.py @@ -11,26 +11,26 @@ def fiber(cursor, skip, q, dt): controllerObj.setup(id='191', name='test01', description=desc) readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader', - path='/home/nanosat/data/hysell_data20/pdata', + path='/home/nanosat/data/sp1_f0', 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, + verbose=1 #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') - # + # procUnitConfObj2.addParameter(name='nipp', value='5', format='int') + procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId()) opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other') @@ -44,10 +44,19 @@ def fiber(cursor, skip, q, dt): # opObj11.addParameter(name='save', value='1', format='int') # opObj11.addParameter(name='figpath', value=figpath, format='str') - # opObj11 = procUnitConfObj2.addOperation(name='RTIPlot', optype='other') + # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other') + # opObj11.addParameter(name='channelList', value='0', format='intList') + # 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='colormap', value='0', format='bool') + # opObj11.addParameter(name='onlySNR', value='1', format='bool') + # opObj11.addParameter(name='DOP', value='0', format='bool') + # # opObj11.addParameter(name='showSNR', value='1', format='bool') + # # opObj11.addParameter(name='SNRthresh', value='0', format='int') + # opObj11.addParameter(name='SNRmin', value='-10', format='int') + # opObj11.addParameter(name='SNRmax', value='30', format='int') + + # opObj11.addParameter(name='showSNR', value='1', 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') @@ -60,13 +69,14 @@ def fiber(cursor, skip, q, dt): # opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other') opObj12.addParameter(name='zeromq', value=1, format='int') + opObj12.addParameter(name='verbose', value=0, format='bool') # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') # opObj13.addParameter(name='zeromq', value=1, format='int') # opObj13.addParameter(name='server', value="juanca", format='str') - opObj12.addParameter(name='delay', value=1, format='int') + opObj12.addParameter(name='delay', value=0, format='int') # print "Escribiendo el archivo XML" @@ -84,4 +94,4 @@ if __name__ == '__main__': parser = argparse.ArgumentParser(description='Set number of parallel processes') parser.add_argument('--nProcess', default=1, type=int) args = parser.parse_args() - multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26') + multiSchain(fiber, nProcess=args.nProcess, startDate='2017/01/26', endDate='2017/01/28') diff --git a/schainpy/scripts/julia_mp.py b/schainpy/scripts/julia_mp.py index 0743086..d812999 100644 --- a/schainpy/scripts/julia_mp.py +++ b/schainpy/scripts/julia_mp.py @@ -1,75 +1,97 @@ -#!/usr/bin/env python -''' -Created on Jul 7, 2014 +import argparse -@author: roj-idl71 -''' -import os, sys -from datetime import datetime, timedelta -import multiprocessing -from schainpy.controller import Project +from schainpy.controller import Project, multiSchain -def main(date): +desc = "HF_EXAMPLE" - controllerObj = Project() - - controllerObj.setup(id='191', name='test01', description='') - - readUnitConfObj = controllerObj.addReadUnit(datatype='Spectra', - path='/home/nanosat/data/zeus', - 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') - - - opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other') - opObj11.addParameter(name='id', value='10', format='int') - 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') +def fiber(cursor, skip, q, dt): + controllerObj = Project() - - - 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') - + controllerObj.setup(id='191', name='test01', description=desc) + + readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader', + path='/home/nanosat/data/julia', + 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()) + # procUnitConfObj2.addParameter(name='nipp', value='5', format='int') + + # procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId()) + # opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other') + + # + # 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') + + # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other') + # opObj11.addParameter(name='channelList', value='0', format='intList') + # + # opObj11.addParameter(name='id', value='2000', format='int') + # # opObj11.addParameter(name='colormap', value='0', format='bool') + # opObj11.addParameter(name='onlySNR', value='1', format='bool') + # opObj11.addParameter(name='DOP', value='0', format='bool') + # opObj11.addParameter(name='showSNR', value='1', format='bool') + # opObj11.addParameter(name='SNRthresh', value='0', format='int') + # opObj11.addParameter(name='SNRmin', value='-10', format='int') + # opObj11.addParameter(name='SNRmax', value='30', format='int') + + # opObj11.addParameter(name='showSNR', value='1', 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') + + # opObj11.addParameter(name='zmin', value='-110', format='float') + # opObj11.addParameter(name='zmax', value='-70', format='float') + # opObj11.addParameter(name='save', value='0', format='int') + # # opObj11.addParameter(name='figpath', value='/tmp/', format='str') + # + opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other') + opObj12.addParameter(name='zeromq', value=1, format='int') + # opObj12.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str') + + + # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') + # opObj13.addParameter(name='zeromq', value=1, format='int') + # opObj13.addParameter(name='server', value="juanca", format='str') + + # opObj12.addParameter(name='delay', value=1, format='int') + + + # print "Escribiendo el archivo XML" + # controllerObj.writeXml(filename) + # print "Leyendo el archivo XML" + # controllerObj.readXml(filename) + + + # timeit.timeit('controllerObj.run()', number=2) controllerObj.start() -if __name__=='__main__': - - dt = datetime(2017, 1, 12) - - dates = [(dt+timedelta(x)).strftime('%Y/%m/%d') for x in range(20)] - p = multiprocessing.Pool(4) - p.map(main, dates) +if __name__ == '__main__': + parser = argparse.ArgumentParser(description='Set number of parallel processes') + parser.add_argument('--nProcess', default=1, type=int) + args = parser.parse_args() + multiSchain(fiber, nProcess=args.nProcess, startDate='2016/08/19', endDate='2016/08/19') diff --git a/schainpy/scripts/receiver.py b/schainpy/scripts/receiver.py index ba5dcf5..16accd1 100644 --- a/schainpy/scripts/receiver.py +++ b/schainpy/scripts/receiver.py @@ -16,9 +16,9 @@ if __name__ == '__main__': proc1 = controllerObj.addProcUnit(name='ReceiverData') proc1.addParameter(name='realtime', value='0', format='bool') - proc1.addParameter(name='plottypes', value='rti,coh,phase,snr,dop', format='str') + proc1.addParameter(name='plottypes', value='rti,coh,phase', format='str') proc1.addParameter(name='throttle', value='10', format='int') - proc1.addParameter(name='plot_server', value='tcp://10.10.10.82:7000', format='str') + # proc1.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str') ## TODO Agregar direccion de server de publicacion a graficos como variable op1 = proc1.addOperation(name='PlotRTIData', optype='other') @@ -32,26 +32,26 @@ if __name__ == '__main__': op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str') op2.addParameter(name='colormap', value='jet', format='str') op2.addParameter(name='show', value='0', format='bool') - # # + # # # op6 = proc1.addOperation(name='PlotPHASEData', optype='other') op6.addParameter(name='wintitle', value='Julia 150Km', format='str') op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str') op6.addParameter(name='show', value='1', format='bool') - # - # proc2 = controllerObj.addProcUnit(name='ReceiverData') - # proc2.addParameter(name='server', value='juanca', format='str') - # proc2.addParameter(name='plottypes', value='snr,dop', format='str') - # - op3 = proc1.addOperation(name='PlotSNRData', optype='other') - op3.addParameter(name='wintitle', value='Julia 150Km', format='str') - op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str') - op3.addParameter(name='show', value='0', format='bool') - # - op4 = proc1.addOperation(name='PlotDOPData', optype='other') - op4.addParameter(name='wintitle', value='Julia 150Km', format='str') - op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str') - op4.addParameter(name='show', value='0', format='bool') - op4.addParameter(name='colormap', value='jet', format='str') + # # + # # proc2 = controllerObj.addProcUnit(name='ReceiverData') + # # proc2.addParameter(name='server', value='juanca', format='str') + # # proc2.addParameter(name='plottypes', value='snr,dop', format='str') + # # + # op3 = proc1.addOperation(name='PlotSNRData', optype='other') + # op3.addParameter(name='wintitle', value='Julia 150Km', format='str') + # op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str') + # op3.addParameter(name='show', value='0', format='bool') + # # + # op4 = proc1.addOperation(name='PlotDOPData', optype='other') + # op4.addParameter(name='wintitle', value='Julia 150Km', format='str') + # op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str') + # op4.addParameter(name='show', value='0', format='bool') + # op4.addParameter(name='colormap', value='jet', format='str') diff --git a/schainpy/scripts/schain.xml b/schainpy/scripts/schain.xml index 6497cc5..9a5d12d 100644 --- a/schainpy/scripts/schain.xml +++ b/schainpy/scripts/schain.xml @@ -1 +1 @@ - \ No newline at end of file + \ No newline at end of file diff --git a/setup.py b/setup.py index a0f14e8..3fe773f 100644 --- a/setup.py +++ b/setup.py @@ -44,5 +44,6 @@ setup(name="schainpy", "paramiko >= 2.1.2", "paho-mqtt >= 1.2", "zmq", + "fuzzywuzzy" ], - ) \ No newline at end of file + )