From 33202d47ce4aa0e1688e28c7bb57b090e942bda3 Mon Sep 17 00:00:00 2001 From: Tom Kralidis Date: Tue, 25 Apr 2023 12:31:35 -0400 Subject: [PATCH] remove ERDDAP plugin (now in pygeoapi core) --- wis2box_api/plugins/provider/erddap.py | 127 ------------------------- 1 file changed, 127 deletions(-) delete mode 100644 wis2box_api/plugins/provider/erddap.py diff --git a/wis2box_api/plugins/provider/erddap.py b/wis2box_api/plugins/provider/erddap.py deleted file mode 100644 index 3f954cc..0000000 --- a/wis2box_api/plugins/provider/erddap.py +++ /dev/null @@ -1,127 +0,0 @@ -############################################################################### -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# -############################################################################### - - -# feature provider for ERDDAP integrations -# -# sample configuration -# -# providers: -# - type: feature -# name: wis2box_api.plugins.provider.erddap.ERDDAPProvider -# data: http://osmc.noaa.gov/erddap/tabledap/OSMC_Points -# id_field: id -# time_field: time -# options: -# query: "?" -# filters: "¶meter=\"SLP\"&platform!=\"C-MAN%20WEATHER%20STATIONS\"&platform!=\"TIDE GAUGE STATIONS (GENERIC)\"" # noqa -# max_age_hours: 12 - - -from datetime import datetime, timedelta, timezone -import json -import logging - -import requests - -from pygeoapi.provider.base import BaseProvider, ProviderQueryError - -LOGGER = logging.getLogger(__name__) - - -class ERDDAPProvider(BaseProvider): - def __init__(self, provider_def): - super().__init__(provider_def) - - LOGGER.debug('Setting provider query filters') - self.query_ = self.options.get('query', '') - self.filters = self.options.get('filters', '') - self.station_id_field = self.options.get('station_id') - self.fields = self.get_fields() - - def get_fields(self): - properties = self.query()['features'][0]['properties'] - for key, value in properties.items(): - LOGGER.debug(key, value) - properties[key] = {'type': type(value).__name__} - return properties - - def query(self, startindex=0, limit=10, resulttype='results', - bbox=[], datetime_=None, properties=[], sortby=[], - select_properties=[], skip_geometry=False, q=None, - filterq=None, **kwargs): - - url = self.data - - url = f'{url}.geoJson{self.query_}{self.filters}' - - timefilter = '' - - max_age_hours = self.options.get('max_age_hours') - if max_age_hours is not None: - LOGGER.debug('Setting time filter') - currenttime = datetime.now(timezone.utc) - mintime = currenttime - timedelta(hours=max_age_hours) - mintime = mintime.strftime('%Y-%m-%dT%H:%M:%SZ') - timefilter = f'&time>={mintime}' - - url = f'{url}{timefilter}' - - LOGGER.debug(f'Fetching data from {url}') - data = json.loads(requests.get(url).text)['features'][startindex:limit] - - # add id to each feature as this is required by pygeoapi - for idx in range(len(data)): - # ID used to extract individual features - try: - station_id = data[idx]['properties'][self.station_id_field] - except KeyError: - # ERDDAP changes case of parameters depending on result - station_id = data[idx]['properties'][self.station_id_field.upper()] # noqa - except Exception as err: - msg = 'Cannot determine station identifier' - LOGGER.error(msg, err) - raise ProviderQueryError(msg) - - obs_time = data[idx]['properties']['time'] - obs_id = f'{station_id}.{obs_time}' - data[idx]['id'] = obs_id - - return { - 'type': 'FeatureCollection', - 'features': data - } - - def get(self, identifier, **kwargs): - url = self.data - - station_id, obs_time = identifier.split('.') - id_filter = f'&time={obs_time}&{self.station_id_field}=%22{station_id}%22' # noqa - - filters = f'{self.filters}{id_filter}' - url = f'{url}.geoJson{self.query_}{filters}' - LOGGER.debug(f'Fetching data from {url}') - data = json.loads(requests.get(url).text)['features'] - if len(data) > 1: - LOGGER.warning(f'More than 1 feature returned for {identifier}, features truncated') # noqa - data = data[0] - data['id'] = identifier - return data