e1291395b0
optional/default/keyword args Change-Id: Iaab83d9915899d96114c078fb82c99be3b59e0dc Former-commit-id: 66804918e06afc9616fcfe0f0a12afd75a8143e1
132 lines
4.4 KiB
Python
132 lines
4.4 KiB
Python
# #
|
|
# This software was developed and / or modified by Raytheon Company,
|
|
# pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
#
|
|
# U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
# This software product contains export-restricted data whose
|
|
# export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
# to non-U.S. persons whether in the United States or abroad requires
|
|
# an export license or other authorization.
|
|
#
|
|
# Contractor Name: Raytheon Company
|
|
# Contractor Address: 6825 Pine Street, Suite 340
|
|
# Mail Stop B8
|
|
# Omaha, NE 68106
|
|
# 402.291.0100
|
|
#
|
|
# See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
# further licensing information.
|
|
# #
|
|
|
|
|
|
#
|
|
# Routes requests to the Data Access Framework through JEP to the Java classes.
|
|
# Returns Python objects that wrap Java objects.
|
|
#
|
|
#
|
|
#
|
|
# SOFTWARE HISTORY
|
|
#
|
|
# Date Ticket# Engineer Description
|
|
# ------------ ---------- ----------- --------------------------
|
|
# 12/10/12 njensen Initial Creation.
|
|
# 02/14/13 1614 bsteffen refactor data access framework
|
|
# to use single request.
|
|
# 03/03/14 2673 bsteffen Add ability to query only ref times.
|
|
# 07/22/14 3185 njensen Added optional/default args to newDataRequest
|
|
#
|
|
#
|
|
#
|
|
|
|
from ufpy.dataaccess import IDataRequest
|
|
|
|
from com.raytheon.uf.common.dataaccess import DataAccessLayer as JavaDataAccessLayer
|
|
from com.raytheon.uf.common.dataaccess.impl import DefaultDataRequest
|
|
from com.raytheon.uf.common.time import DataTime as JavaDataTime
|
|
from com.raytheon.uf.common.geospatial import LatLonReprojection
|
|
from com.raytheon.uf.common.python import PythonNumpyFloatArray
|
|
|
|
import jep
|
|
import DataTime
|
|
import JGeometryData, JGridData, JDataRequest
|
|
|
|
|
|
def getAvailableTimes(request, refTimeOnly):
|
|
javaTimes = JavaDataAccessLayer.getAvailableTimes(request.toJavaObj(), refTimeOnly)
|
|
times = []
|
|
for jt in javaTimes:
|
|
times.append(DataTime.DataTime(jt))
|
|
return times
|
|
|
|
|
|
def getGridData(request, times):
|
|
if type(times) is list:
|
|
# presuming list of DataTimes
|
|
jtimes = jep.jarray(len(times), JavaDataTime)
|
|
for i in xrange(len(times)):
|
|
jtimes[i] = times[i].toJavaObj()
|
|
javaData = JavaDataAccessLayer.getGridData(request.toJavaObj(), jtimes)
|
|
else:
|
|
# presuming TimeRange
|
|
javaData = JavaDataAccessLayer.getGridData(request.toJavaObj(), times.toJavaObj())
|
|
data = []
|
|
for jd in javaData:
|
|
data.append(JGridData.JGridData(jd))
|
|
return data
|
|
|
|
def getGeometryData(request, times):
|
|
if type(times) is list:
|
|
# presuming list of DataTimes
|
|
jtimes = jep.jarray(len(times), JavaDataTime)
|
|
for i in xrange(len(times)):
|
|
jtimes[i] = times[i].toJavaObj()
|
|
javaData = JavaDataAccessLayer.getGeometryData(request.toJavaObj(), jtimes)
|
|
else:
|
|
# presuming TimeRange
|
|
javaData = JavaDataAccessLayer.getGeometryData(request.toJavaObj(), times.toJavaObj())
|
|
data = []
|
|
for jd in javaData:
|
|
data.append(JGeometryData.JGeometryData(jd))
|
|
return data
|
|
|
|
def getAvailableLocationNames(request):
|
|
return JavaDataAccessLayer.getAvailableLocationNames(request.toJavaObj())
|
|
|
|
def getAvailableParameters(request):
|
|
# TODO
|
|
raise Exception('Not implemented yet')
|
|
|
|
def getAvailableLevels(request):
|
|
# TODO
|
|
raise Exception('Not implemented yet')
|
|
|
|
def getRequiredIdentifiers(datatype):
|
|
# TODO
|
|
raise Exception('Not implemented yet')
|
|
|
|
def getValidIdentifiers(datatype):
|
|
# TODO
|
|
raise Exception('Not implemented yet')
|
|
|
|
def newDataRequest(datatype, parameters=[], levels=[], locationNames = [], envelope=None, **kwargs):
|
|
req = JDataRequest.JDataRequest(DefaultDataRequest())
|
|
if datatype:
|
|
req.setDatatype(datatype)
|
|
if parameters:
|
|
req.setParameters(*parameters)
|
|
if levels:
|
|
req.setLevels(*levels)
|
|
if locationNames:
|
|
req.setLocationNames(*locationNames)
|
|
if envelope:
|
|
req.setEnvelope(envelope)
|
|
if kwargs:
|
|
# any args leftover are assumed to be identifiers
|
|
for key in kwargs:
|
|
req.addIdentifier(key, kwargs[key])
|
|
return req
|
|
|
|
def getSupportedDatatypes():
|
|
# TODO
|
|
raise Exception('Not implemented yet')
|
|
|