##// END OF EJS Templates
schain
RSS
Merge branch 'v3.0-WR' of http://intranet.igp.gob.pe:8082/schain into v3.0-WR
Merge branch 'v3.0-WR' of http://intranet.igp.gob.pe:8082/schain into v3.0-WR
Juan C. Espinoza - - Load All Authors

File last commit:

r1539:03a9c71b14ee merge
r1539:03a9c71b14ee merge
Show More
jroplot_parameters.py
690 lines | 22.4 KiB | text/x-python | PythonLexer
/ schainpy / model / graphics / jroplot_parameters.py
History | Source | Raw |Copy content |Copy permalink
Julio Valdez
Processing Modules added:...
 r502 import os
import datetime
Juan C. Espinoza
Use function elaz to latlon instead of wradlib
 r1530 import warnings
Julio Valdez
Processing Modules added:...
 r502 import numpy
rflores
Block360Update
 r1439 from mpl_toolkits.axisartist.grid_finder import FixedLocator, DictFormatter
ebocanegra
15/08/2017
 r1001
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 from schainpy.model.graphics.jroplot_base import Plot, plt
Danny Scipión
Se inclute SpectralMoments y DoubleGaussianPlot de tipo SpectraPlot
 r1358 from schainpy.model.graphics.jroplot_spectra import SpectraPlot, RTIPlot, CoherencePlot, SpectraCutPlot
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 from schainpy.utils import log
Juan C. Espinoza
Add georef for realtime
 r1498
ebocanegra
15/08/2017
 r1001
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 EARTH_RADIUS = 6.3710e3
ebocanegra
15/08/2017
 r1001
Juan C. Espinoza
Use function elaz to latlon instead of wradlib
 r1530 def antenna_to_cartesian(ranges, azimuths, elevations):
"""
Return Cartesian coordinates from antenna coordinates.
Parameters
----------
ranges : array
Distances to the center of the radar gates (bins) in kilometers.
azimuths : array
Azimuth angle of the radar in degrees.
elevations : array
Elevation angle of the radar in degrees.
Returns
-------
x, y, z : array
Cartesian coordinates in meters from the radar.
Notes
-----
The calculation for Cartesian coordinate is adapted from equations
2.28(b) and 2.28(c) of Doviak and Zrnic [1]_ assuming a
standard atmosphere (4/3 Earth's radius model).
.. math::
z = \\sqrt{r^2+R^2+2*r*R*sin(\\theta_e)} - R
s = R * arcsin(\\frac{r*cos(\\theta_e)}{R+z})
x = s * sin(\\theta_a)
y = s * cos(\\theta_a)
Where r is the distance from the radar to the center of the gate,
:math:`\\theta_a` is the azimuth angle, :math:`\\theta_e` is the
elevation angle, s is the arc length, and R is the effective radius
of the earth, taken to be 4/3 the mean radius of earth (6371 km).
References
----------
.. [1] Doviak and Zrnic, Doppler Radar and Weather Observations, Second
Edition, 1993, p. 21.
"""
theta_e = numpy.deg2rad(elevations) # elevation angle in radians.
theta_a = numpy.deg2rad(azimuths) # azimuth angle in radians.
R = 6371.0 * 1000.0 * 4.0 / 3.0 # effective radius of earth in meters.
r = ranges * 1000.0 # distances to gates in meters.
z = (r ** 2 + R ** 2 + 2.0 * r * R * numpy.sin(theta_e)) ** 0.5 - R
s = R * numpy.arcsin(r * numpy.cos(theta_e) / (R + z)) # arc length in m.
x = s * numpy.sin(theta_a)
y = s * numpy.cos(theta_a)
return x, y, z
def cartesian_to_geographic_aeqd(x, y, lon_0, lat_0, R=EARTH_RADIUS):
"""
Azimuthal equidistant Cartesian to geographic coordinate transform.
Transform a set of Cartesian/Cartographic coordinates (x, y) to
geographic coordinate system (lat, lon) using a azimuthal equidistant
map projection [1]_.
.. math::
lat = \\arcsin(\\cos(c) * \\sin(lat_0) +
(y * \\sin(c) * \\cos(lat_0) / \\rho))
lon = lon_0 + \\arctan2(
x * \\sin(c),
\\rho * \\cos(lat_0) * \\cos(c) - y * \\sin(lat_0) * \\sin(c))
\\rho = \\sqrt(x^2 + y^2)
c = \\rho / R
Where x, y are the Cartesian position from the center of projection;
lat, lon the corresponding latitude and longitude; lat_0, lon_0 are the
latitude and longitude of the center of the projection; R is the radius of
the earth (defaults to ~6371 km). lon is adjusted to be between -180 and
180.
Parameters
----------
x, y : array-like
Cartesian coordinates in the same units as R, typically meters.
lon_0, lat_0 : float
Longitude and latitude, in degrees, of the center of the projection.
R : float, optional
Earth radius in the same units as x and y. The default value is in
units of meters.
Returns
-------
lon, lat : array
Longitude and latitude of Cartesian coordinates in degrees.
References
----------
.. [1] Snyder, J. P. Map Projections--A Working Manual. U. S. Geological
Survey Professional Paper 1395, 1987, pp. 191-202.
"""
x = numpy.atleast_1d(numpy.asarray(x))
y = numpy.atleast_1d(numpy.asarray(y))
lat_0_rad = numpy.deg2rad(lat_0)
lon_0_rad = numpy.deg2rad(lon_0)
rho = numpy.sqrt(x*x + y*y)
c = rho / R
with warnings.catch_warnings():
# division by zero may occur here but is properly addressed below so
# the warnings can be ignored
warnings.simplefilter("ignore", RuntimeWarning)
lat_rad = numpy.arcsin(numpy.cos(c) * numpy.sin(lat_0_rad) +
y * numpy.sin(c) * numpy.cos(lat_0_rad) / rho)
lat_deg = numpy.rad2deg(lat_rad)
# fix cases where the distance from the center of the projection is zero
lat_deg[rho == 0] = lat_0
x1 = x * numpy.sin(c)
x2 = rho*numpy.cos(lat_0_rad)*numpy.cos(c) - y*numpy.sin(lat_0_rad)*numpy.sin(c)
lon_rad = lon_0_rad + numpy.arctan2(x1, x2)
lon_deg = numpy.rad2deg(lon_rad)
# Longitudes should be from -180 to 180 degrees
lon_deg[lon_deg > 180] -= 360.
lon_deg[lon_deg < -180] += 360.
return lon_deg, lat_deg
def antenna_to_geographic(ranges, azimuths, elevations, site):
x, y, z = antenna_to_cartesian(numpy.array(ranges), numpy.array(azimuths), numpy.array(elevations))
lon, lat = cartesian_to_geographic_aeqd(x, y, site[0], site[1], R=6370997.)
return lon, lat
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 def ll2xy(lat1, lon1, lat2, lon2):
ebocanegra
15/08/2017
 r1001
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 p = 0.017453292519943295
a = 0.5 - numpy.cos((lat2 - lat1) * p)/2 + numpy.cos(lat1 * p) * \
numpy.cos(lat2 * p) * (1 - numpy.cos((lon2 - lon1) * p)) / 2
r = 12742 * numpy.arcsin(numpy.sqrt(a))
theta = numpy.arctan2(numpy.sin((lon2-lon1)*p)*numpy.cos(lat2*p), numpy.cos(lat1*p)
* numpy.sin(lat2*p)-numpy.sin(lat1*p)*numpy.cos(lat2*p)*numpy.cos((lon2-lon1)*p))
theta = -theta + numpy.pi/2
return r*numpy.cos(theta), r*numpy.sin(theta)
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 def km2deg(km):
'''
Convert distance in km to degrees
'''
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 return numpy.rad2deg(km/EARTH_RADIUS)
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 class SpectralMomentsPlot(SpectraPlot):
'''
Plot for Spectral Moments
'''
CODE = 'spc_moments'
Danny Scipión
Se inclute SpectralMoments y DoubleGaussianPlot de tipo SpectraPlot
 r1358 # colormap = 'jet'
# plot_type = 'pcolor'
class DobleGaussianPlot(SpectraPlot):
'''
Plot for Double Gaussian Plot
'''
CODE = 'gaussian_fit'
# colormap = 'jet'
# plot_type = 'pcolor'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Danny Scipión
Se inclute SpectralMoments y DoubleGaussianPlot de tipo SpectraPlot
 r1358 class DoubleGaussianSpectraCutPlot(SpectraCutPlot):
'''
Plot SpectraCut with Double Gaussian Fit
'''
CODE = 'cut_gaussian_fit'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 class SnrPlot(RTIPlot):
'''
Plot for SNR Data
'''
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 CODE = 'snr'
colormap = 'jet'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 def update(self, dataOut):
data = {
avaldez
19 DE AGOSTO 2021 RM
 r1367 'snr': 10*numpy.log10(dataOut.data_snr)
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 }
return data, {}
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 class DopplerPlot(RTIPlot):
'''
Plot for DOPPLER Data (1st moment)
'''
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 CODE = 'dop'
colormap = 'jet'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 def update(self, dataOut):
data = {
avaldez
19 DE AGOSTO 2021 RM
 r1367 'dop': 10*numpy.log10(dataOut.data_dop)
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 }
return data, {}
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 class PowerPlot(RTIPlot):
'''
Plot for Power Data (0 moment)
'''
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 CODE = 'pow'
colormap = 'jet'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 def update(self, dataOut):
data = {
avaldez
19 DE AGOSTO 2021 RM
 r1367 'pow': 10*numpy.log10(dataOut.data_pow/dataOut.normFactor)
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 }
return data, {}
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 class SpectralWidthPlot(RTIPlot):
'''
Plot for Spectral Width Data (2nd moment)
'''
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 CODE = 'width'
colormap = 'jet'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 def update(self, dataOut):
data = {
'width': dataOut.data_width
}
return data, {}
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 class SkyMapPlot(Plot):
'''
Plot for meteors detection data
'''
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 CODE = 'param'
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 def setup(self):
Julio Valdez
Processing Modules added:...
 r502
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.ncols = 1
self.nrows = 1
self.width = 7.2
self.height = 7.2
self.nplots = 1
self.xlabel = 'Zonal Zenith Angle (deg)'
self.ylabel = 'Meridional Zenith Angle (deg)'
self.polar = True
self.ymin = -180
self.ymax = 180
self.colorbar = False
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 def plot(self):
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 arrayParameters = numpy.concatenate(self.data['param'])
error = arrayParameters[:, -1]
indValid = numpy.where(error == 0)[0]
finalMeteor = arrayParameters[indValid, :]
finalAzimuth = finalMeteor[:, 3]
finalZenith = finalMeteor[:, 4]
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 x = finalAzimuth * numpy.pi / 180
y = finalZenith
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 ax = self.axes[0]
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 if ax.firsttime:
ax.plot = ax.plot(x, y, 'bo', markersize=5)[0]
Julio Valdez
-Parameters Plot corrected...
 r832 else:
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 ax.plot.set_data(x, y)
dt1 = self.getDateTime(self.data.min_time).strftime('%y/%m/%d %H:%M:%S')
dt2 = self.getDateTime(self.data.max_time).strftime('%y/%m/%d %H:%M:%S')
title = 'Meteor Detection Sky Map\n %s - %s \n Number of events: %5.0f\n' % (dt1,
dt2,
len(x))
self.titles[0] = title
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 class GenericRTIPlot(Plot):
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 '''
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 Plot for data_xxxx object
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 '''
CODE = 'param'
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 colormap = 'viridis'
plot_type = 'pcolorbuffer'
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285
def setup(self):
self.xaxis = 'time'
self.ncols = 1
jespinoza
Fix bugs in SpectraCutPlot, GenericRTIPlot and saving when using throttle
 r1359 self.nrows = self.data.shape('param')[0]
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.nplots = self.nrows
Juan C. Espinoza
Fix ParametersPlot & BLTRParamReader
 r1322 self.plots_adjust.update({'hspace':0.8, 'left': 0.1, 'bottom': 0.08, 'right':0.95, 'top': 0.95})
avaldez
19 DE AGOSTO 2021 RM
 r1367
Juan C. Espinoza
Fix ParametersPlot & BLTRParamReader
 r1322 if not self.xlabel:
self.xlabel = 'Time'
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285
Danny Scipión
Se inclute SpectralMoments y DoubleGaussianPlot de tipo SpectraPlot
 r1358 self.ylabel = 'Range [km]'
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 if not self.titles:
jespinoza
Fix h5py Dataset value attribute deprecation
 r1360 self.titles = ['Param {}'.format(x) for x in range(self.nrows)]
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 def update(self, dataOut):
data = {
jespinoza
Fix bugs in SpectraCutPlot, GenericRTIPlot and saving when using throttle
 r1359 'param' : numpy.concatenate([getattr(dataOut, attr) for attr in self.attr_data], axis=0)
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 }
meta = {}
return data, meta
avaldez
19 DE AGOSTO 2021 RM
 r1367
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 def plot(self):
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 # self.data.normalize_heights()
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.x = self.data.times
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 self.y = self.data.yrange
jespinoza
Fix bugs in SpectraCutPlot, GenericRTIPlot and saving when using throttle
 r1359 self.z = self.data['param']
david c
update de procesamiento y revision de ploteo
 r1378 self.z = 10*numpy.log10(self.z)
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.z = numpy.ma.masked_invalid(self.z)
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 if self.decimation is None:
x, y, z = self.fill_gaps(self.x, self.y, self.z)
Julio Valdez
-Added Radial Velocity graphic ...
 r511 else:
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 x, y, z = self.fill_gaps(*self.decimate())
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 for n, ax in enumerate(self.axes):
Miguel Valdez
parametrs plotting: SNR and DOP arguments have been added
 r588
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.zmax = self.zmax if self.zmax is not None else numpy.max(
self.z[n])
self.zmin = self.zmin if self.zmin is not None else numpy.min(
self.z[n])
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 if ax.firsttime:
if self.zlimits is not None:
self.zmin, self.zmax = self.zlimits[n]
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 ax.plt = ax.pcolormesh(x, y, z[n].T * self.factors[n],
vmin=self.zmin,
vmax=self.zmax,
cmap=self.cmaps[n]
)
else:
if self.zlimits is not None:
self.zmin, self.zmax = self.zlimits[n]
ax.collections.remove(ax.collections[0])
ax.plt = ax.pcolormesh(x, y, z[n].T * self.factors[n],
vmin=self.zmin,
vmax=self.zmax,
cmap=self.cmaps[n]
)
class PolarMapPlot(Plot):
'''
Plot for weather radar
'''
CODE = 'param'
colormap = 'seismic'
def setup(self):
self.ncols = 1
self.nrows = 1
self.width = 9
self.height = 8
self.mode = self.data.meta['mode']
if self.channels is not None:
self.nplots = len(self.channels)
self.nrows = len(self.channels)
jespinoza
MADReader support for HDF5 (mad2 & mad3)
 r1065 else:
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.nplots = self.data.shape(self.CODE)[0]
self.nrows = self.nplots
self.channels = list(range(self.nplots))
if self.mode == 'E':
self.xlabel = 'Longitude'
self.ylabel = 'Latitude'
else:
self.xlabel = 'Range (km)'
self.ylabel = 'Height (km)'
self.bgcolor = 'white'
self.cb_labels = self.data.meta['units']
self.lat = self.data.meta['latitude']
self.lon = self.data.meta['longitude']
self.xmin, self.xmax = float(
km2deg(self.xmin) + self.lon), float(km2deg(self.xmax) + self.lon)
self.ymin, self.ymax = float(
km2deg(self.ymin) + self.lat), float(km2deg(self.ymax) + self.lat)
# self.polar = True
def plot(self):
for n, ax in enumerate(self.axes):
data = self.data['param'][self.channels[n]]
zeniths = numpy.linspace(
0, self.data.meta['max_range'], data.shape[1])
if self.mode == 'E':
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 azimuths = -numpy.radians(self.data.yrange)+numpy.pi/2
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 r, theta = numpy.meshgrid(zeniths, azimuths)
x, y = r*numpy.cos(theta)*numpy.cos(numpy.radians(self.data.meta['elevation'])), r*numpy.sin(
theta)*numpy.cos(numpy.radians(self.data.meta['elevation']))
x = km2deg(x) + self.lon
y = km2deg(y) + self.lat
jespinoza
MADReader support for HDF5 (mad2 & mad3)
 r1065 else:
jespinoza
Add update method to plots to pass data (no more changes in jrodata)
 r1343 azimuths = numpy.radians(self.data.yrange)
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 r, theta = numpy.meshgrid(zeniths, azimuths)
x, y = r*numpy.cos(theta), r*numpy.sin(theta)
self.y = zeniths
if ax.firsttime:
if self.zlimits is not None:
self.zmin, self.zmax = self.zlimits[n]
ax.plt = ax.pcolormesh( # r, theta, numpy.ma.array(data, mask=numpy.isnan(data)),
x, y, numpy.ma.array(data, mask=numpy.isnan(data)),
vmin=self.zmin,
vmax=self.zmax,
cmap=self.cmaps[n])
Julio Valdez
First Spectral Fitting and EW Drifts operative module inside Signal Chain TRUNK
 r513 else:
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 if self.zlimits is not None:
self.zmin, self.zmax = self.zlimits[n]
ax.collections.remove(ax.collections[0])
ax.plt = ax.pcolormesh( # r, theta, numpy.ma.array(data, mask=numpy.isnan(data)),
x, y, numpy.ma.array(data, mask=numpy.isnan(data)),
vmin=self.zmin,
vmax=self.zmax,
cmap=self.cmaps[n])
if self.mode == 'A':
continue
# plot district names
f = open('/data/workspace/schain_scripts/distrito.csv')
for line in f:
label, lon, lat = [s.strip() for s in line.split(',') if s]
lat = float(lat)
lon = float(lon)
# ax.plot(lon, lat, '.b', ms=2)
ax.text(lon, lat, label.decode('utf8'), ha='center',
va='bottom', size='8', color='black')
# plot limites
limites = []
tmp = []
for line in open('/data/workspace/schain_scripts/lima.csv'):
if '#' in line:
if tmp:
limites.append(tmp)
tmp = []
continue
values = line.strip().split(',')
tmp.append((float(values[0]), float(values[1])))
for points in limites:
ax.add_patch(
Polygon(points, ec='k', fc='none', ls='--', lw=0.5))
# plot Cuencas
for cuenca in ('rimac', 'lurin', 'mala', 'chillon', 'chilca', 'chancay-huaral'):
f = open('/data/workspace/schain_scripts/{}.csv'.format(cuenca))
values = [line.strip().split(',') for line in f]
points = [(float(s[0]), float(s[1])) for s in values]
ax.add_patch(Polygon(points, ec='b', fc='none'))
# plot grid
for r in (15, 30, 45, 60):
ax.add_artist(plt.Circle((self.lon, self.lat),
km2deg(r), color='0.6', fill=False, lw=0.2))
ax.text(
self.lon + (km2deg(r))*numpy.cos(60*numpy.pi/180),
self.lat + (km2deg(r))*numpy.sin(60*numpy.pi/180),
'{}km'.format(r),
ha='center', va='bottom', size='8', color='0.6', weight='heavy')
if self.mode == 'E':
title = 'El={}$^\circ$'.format(self.data.meta['elevation'])
label = 'E{:02d}'.format(int(self.data.meta['elevation']))
Julio Valdez
data...
 r608 else:
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 title = 'Az={}$^\circ$'.format(self.data.meta['azimuth'])
label = 'A{:02d}'.format(int(self.data.meta['azimuth']))
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
Juan C. Espinoza
Update and fix plot modules #TODO: correlation & spectraheis
 r1285 self.save_labels = ['{}-{}'.format(lbl, label) for lbl in self.labels]
self.titles = ['{} {}'.format(
self.data.parameters[x], title) for x in self.channels]
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 class WeatherParamsPlot(Plot):
#CODE = 'RHI'
#plot_name = 'RHI'
Juan C. Espinoza
Add georef for realtime
 r1498 plot_type = 'scattermap'
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 buffering = False
def setup(self):
self.ncols = 1
self.nrows = 1
self.nplots= 1
avaldezp
Adjust plots, es adiciona top y se rota el axis de los grados 90 ubicando el 0ª en 90ª
 r1471 self.ylabel= 'Range [km]'
self.xlabel= 'Range [km]'
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 self.polar = True
self.grid = True
if self.channels is not None:
self.nplots = len(self.channels)
self.nrows = len(self.channels)
else:
self.nplots = self.data.shape(self.CODE)[0]
self.nrows = self.nplots
self.channels = list(range(self.nplots))
self.colorbar=True
self.width =8
self.height =8
self.ini =0
self.len_azi =0
self.buffer_ini = None
self.buffer_ele = None
jespinoza
update fix axes, test de prueba de canales
 r1476 self.plots_adjust.update({'wspace': 0.4, 'hspace':0.4, 'left': 0.1, 'right': 0.9, 'bottom': 0.08})
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 self.flag =0
self.indicador= 0
self.last_data_ele = None
self.val_mean = None
def update(self, dataOut):
Juan C. Espinoza
Fix weather proc for multiple parameters
 r1514 vars = {
'S' : 0,
'V' : 1,
'W' : 2,
'SNR' : 3,
'Z' : 4,
'D' : 5,
'P' : 6,
'R' : 7,
}
avaldezp
update jroIO_base.py se adiciona filter, jroIO_param se adicion atributo dparam para identificar data procesada, leer una sola marca de tiempo y en jroplot_parameters se utiliza como flag el dparam para identificar la data procesada y plotearla
 r1534
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 data = {}
meta = {}
avaldezp
update jroIO_base.py se adiciona filter, jroIO_param se adicion atributo dparam para identificar data procesada, leer una sola marca de tiempo y en jroplot_parameters se utiliza como flag el dparam para identificar la data procesada y plotearla
 r1534
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 if hasattr(dataOut, 'nFFTPoints'):
factor = dataOut.normFactor
Juan C. Espinoza
Fix weather proc for multiple parameters
 r1514 else:
factor = 1
avaldezp
Update WeatherParamsPlot
 r1509
avaldezp
update jroIO_base.py se adiciona filter, jroIO_param se adicion atributo dparam para identificar data procesada, leer una sola marca de tiempo y en jroplot_parameters se utiliza como flag el dparam para identificar la data procesada y plotearla
 r1534 if hasattr(dataOut, 'dparam'):
tmp = getattr(dataOut, 'data_param')
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 else:
avaldezp
update jroIO_base.py se adiciona filter, jroIO_param se adicion atributo dparam para identificar data procesada, leer una sola marca de tiempo y en jroplot_parameters se utiliza como flag el dparam para identificar la data procesada y plotearla
 r1534
if 'S' in self.attr_data[0]:
tmp = 10*numpy.log10(10.0*getattr(dataOut, 'data_param')[:,0,:]/(factor))
else:
tmp = getattr(dataOut, 'data_param')[:,vars[self.attr_data[0]],:]
Juan C. Espinoza
change mask attr in Weatherparamplot
 r1515
if self.mask:
mask = dataOut.data_param[:,3,:] < self.mask
tmp = numpy.ma.masked_array(tmp, mask=mask)
Juan C. Espinoza
Add georef for realtime
 r1498
r = dataOut.heightList
delta_height = r[1]-r[0]
valid = numpy.where(r>=0)[0]
data['r'] = numpy.arange(len(valid))*delta_height
try:
data['data'] = tmp[self.channels[0]][:,valid]
except:
data['data'] = tmp[0][:,valid]
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461
if dataOut.mode_op == 'PPI':
self.CODE = 'PPI'
self.title = self.CODE
elif dataOut.mode_op == 'RHI':
self.CODE = 'RHI'
self.title = self.CODE
Juan C. Espinoza
Add georef for realtime
 r1498 data['azi'] = dataOut.data_azi
data['ele'] = dataOut.data_ele
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 data['mode_op'] = dataOut.mode_op
Juan C. Espinoza
Update weatherplot
 r1538 self.mode = dataOut.mode_op
Juan C. Espinoza
Add georef for realtime
 r1498 var = data['data'].flatten()
Juan C. Espinoza
Use function elaz to latlon instead of wradlib
 r1530 r = numpy.tile(data['r'], data['data'].shape[0])
az = numpy.repeat(data['azi'], data['data'].shape[1])
el = numpy.repeat(data['ele'], data['data'].shape[1])
# lla = georef.spherical_to_proj(r, data['azi'], data['ele'], (-75.295893, -12.040436, 3379.2147))
avaldezp
update jroIO_base.py se adiciona filter, jroIO_param se adicion atributo dparam para identificar data procesada, leer una sola marca de tiempo y en jroplot_parameters se utiliza como flag el dparam para identificar la data procesada y plotearla
 r1534
Juan C. Espinoza
Use function elaz to latlon instead of wradlib
 r1530 latlon = antenna_to_geographic(r, az, el, (-75.295893, -12.040436))
Juan C. Espinoza
change mask attr in Weatherparamplot
 r1515 if self.mask:
Juan C. Espinoza
Use function elaz to latlon instead of wradlib
 r1530 meta['lat'] = latlon[1][var.mask==False]
meta['lon'] = latlon[0][var.mask==False]
Juan C. Espinoza
change mask attr in Weatherparamplot
 r1515 data['var'] = numpy.array([var[var.mask==False]])
else:
Juan C. Espinoza
Use function elaz to latlon instead of wradlib
 r1530 meta['lat'] = latlon[1]
meta['lon'] = latlon[0]
Juan C. Espinoza
change mask attr in Weatherparamplot
 r1515 data['var'] = numpy.array([var])
avaldezp
Update WeatherParamsPlot
 r1509
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 return data, meta
def plot(self):
Juan C. Espinoza
Add georef for realtime
 r1498 data = self.data[-1]
z = data['data']
r = data['r']
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 self.titles = []
self.ymax = self.ymax if self.ymax else numpy.nanmax(r)
self.ymin = self.ymin if self.ymin else numpy.nanmin(r)
self.zmax = self.zmax if self.zmax else numpy.nanmax(z)
Juan C. Espinoza
Add snr to block360, mask in plot
 r1488 self.zmin = self.zmin if self.zmin is not None else numpy.nanmin(z)
Juan C. Espinoza
Clean code and fix for one channel in WR
 r1483
avaldezp
update jroIO_base.py se adiciona filter, jroIO_param se adicion atributo dparam para identificar data procesada, leer una sola marca de tiempo y en jroplot_parameters se utiliza como flag el dparam para identificar la data procesada y plotearla
 r1534 if isinstance(data['mode_op'], bytes):
data['mode_op'] = data['mode_op'].decode()
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 if data['mode_op'] == 'RHI':
try:
if self.data['mode_op'][-2] == 'PPI':
self.ang_min = None
self.ang_max = None
except:
pass
self.ang_min = self.ang_min if self.ang_min else 0
self.ang_max = self.ang_max if self.ang_max else 90
r, theta = numpy.meshgrid(r, numpy.radians(data['ele']) )
elif data['mode_op'] == 'PPI':
try:
if self.data['mode_op'][-2] == 'RHI':
self.ang_min = None
self.ang_max = None
except:
pass
self.ang_min = self.ang_min if self.ang_min else 0
self.ang_max = self.ang_max if self.ang_max else 360
r, theta = numpy.meshgrid(r, numpy.radians(data['azi']) )
self.clear_figures()
for i,ax in enumerate(self.axes):
if ax.firsttime:
ax.set_xlim(numpy.radians(self.ang_min),numpy.radians(self.ang_max))
ax.plt = ax.pcolormesh(theta, r, z, cmap=self.colormap, vmin=self.zmin, vmax=self.zmax)
if data['mode_op'] == 'PPI':
ax.set_theta_direction(-1)
avaldezp
Adjust plots, es adiciona top y se rota el axis de los grados 90 ubicando el 0ª en 90ª
 r1471 ax.set_theta_offset(numpy.pi/2)
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 else:
ax.set_xlim(numpy.radians(self.ang_min),numpy.radians(self.ang_max))
ax.plt = ax.pcolormesh(theta, r, z, cmap=self.colormap, vmin=self.zmin, vmax=self.zmax)
if data['mode_op'] == 'PPI':
ax.set_theta_direction(-1)
avaldezp
Adjust plots, es adiciona top y se rota el axis de los grados 90 ubicando el 0ª en 90ª
 r1471 ax.set_theta_offset(numpy.pi/2)
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 ax.grid(True)
if data['mode_op'] == 'RHI':
len_aux = int(data['azi'].shape[0]/4)
mean = numpy.mean(data['azi'][len_aux:-len_aux])
if len(self.channels) !=1:
Juan C. Espinoza
Clean code and fix for one channel in WR
 r1483 self.titles = ['RHI {} at AZ: {} CH {}'.format(self.labels[x], str(round(mean,1)), x) for x in range(self.nrows)]
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 else:
Juan C. Espinoza
Clean code and fix for one channel in WR
 r1483 self.titles = ['RHI {} at AZ: {} CH {}'.format(self.labels[0], str(round(mean,1)), self.channels[0])]
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 elif data['mode_op'] == 'PPI':
len_aux = int(data['ele'].shape[0]/4)
mean = numpy.mean(data['ele'][len_aux:-len_aux])
if len(self.channels) !=1:
Juan C. Espinoza
Update weatherplot
 r1538 self.titles = ['PPI {} at EL: {} CH {}'.format(self.labels[x], str(round(mean,1)), x) for x in range(self.nrows)]
rflores
PPI or RHI mode Detection/GeneralPlot
 r1461 else:
Juan C. Espinoza
Clean code and fix for one channel in WR
 r1483 self.titles = ['PPI {} at EL: {} CH {}'.format(self.labels[0], str(round(mean,1)), self.channels[0])]
Juan C. Espinoza
Update weatherplot
 r1538 self.mode_value = round(mean,1)