weaver.processes.opensearch
¶
Module Contents¶
-
weaver.processes.opensearch.
alter_payload_after_query
(payload)[source]¶ When redeploying the package on ADES, strip out any EOImage parameter.
-
weaver.processes.opensearch.
query_eo_images_from_wps_inputs
(wps_inputs: Ellipsis, eoimage_source_info: Dict[str, Dict], accept_mime_types: Dict[str, List[str]], settings: Optional[weaver.typedefs.AnySettingsContainer] = None) → Dict[str, Deque][source]¶ Query OpenSearch using parameters in inputs and return file links.
- Parameters
wps_inputs – inputs containing info to query
eoimage_source_info – data source info of eoimages
accept_mime_types – dict of list of accepted mime types, ordered by preference
settings – application settings to retrieve request options as necessary.
-
weaver.processes.opensearch.
replace_with_opensearch_scheme
(link)[source]¶ Replaces
file://
scheme byopensearch://
scheme.
-
class
weaver.processes.opensearch.
OpenSearchQuery
(collection_identifier: str, osdd_url: str, catalog_search_field: str = 'parentIdentifier', settings: Optional[weaver.typedefs.AnySettingsContainer] = None)[source]¶ Container to handle OpenSearch queries.
- Parameters
collection_identifier – Collection ID to query
osdd_url – Global OSDD url for OpenSearch queries.
catalog_search_field – Name of the field for the collection identifier.
settings – application settings to retrieve request options as necessary.
-
_prepare_query_url
(self: str, template_url: Dict, params) → Tuple[str, Dict][source]¶ Prepare the URL for the OpenSearch query.
- Parameters
template_url – url containing query parameters.
params – parameters to insert in formatted URL.
-
_query_features_paginated
(self: Dict, params) → Iterable[Dict, str][source]¶ Iterates over paginated results until all features are retrieved.
- Parameters
params – query parameters
-
query_datasets
(self: Dict, params: Tuple, accept_schemes: List, accept_mime_types) → Iterable[str][source]¶ Query the specified datasets.
Loop on every OpenSearch result feature and yield URL matching required mime-type and scheme. Log a warning if a feature cannot yield a valid URL (either no compatible mime-type or scheme)
- Parameters
params – query parameters
accept_schemes – only return links of this scheme
accept_mime_types – list of accepted mime types, ordered by preference
- Raises
KeyError – If the feature doesn’t contain a json data section or an atom alternative link
-
weaver.processes.opensearch.
get_additional_parameters
(input_data: Dict) → List[Tuple[str, str]][source]¶ Retrieve the values from the
additionalParameters
of the input.- Parameters
input_data – Dict containing or not the “additionalParameters” key
-
class
weaver.processes.opensearch.
EOImageDescribeProcessHandler
(inputs)[source]¶ -
-
static
make_toi
(id_, start_date=True)[source]¶ Generate the Time-Of-Interest definition.
- Parameters
id – ID of the input.
start_date – (Default value = True)
-
to_opensearch
(self: bool, unique_aoi: bool, unique_toi) → List[Dict][source]¶ Convert the inputs with OpenSearch request parameters considering Area-Of-Interest and Time-Of-Interest.
- Parameters
unique_aoi – indicate if a single/global AOI must be applied or individual ones for each input.
unique_toi – indicate if a single/global TOI must be applied or individual ones for each input.
-
static
-
weaver.processes.opensearch.
get_original_collection_id
(payload: Dict, wps_inputs: Dict[str, collections.deque]) → Dict[str, collections.deque][source]¶ Obtains modified WPS inputs considering mapping to known OpenSearch collection IDs.
When we deploy a Process that contains OpenSearch parameters, the collection identifier is modified:
Ex: files -> collection Ex: s2 -> collection_s2, probav -> collection_probav
This function changes the ID in the execute request to the one from the deployed Process description.
- Parameters
payload –
wps_inputs –
- Returns
-
weaver.processes.opensearch.
get_eo_images_data_sources
(payload: Dict, wps_inputs: Dict[str, collections.deque]) → Dict[str, Dict][source]¶ Resolve the data source of an
EOImage
input reference.- Parameters
payload – Deploy payload
wps_inputs – Execute inputs
- Returns
Data source of the
EOImage
.
-
weaver.processes.opensearch.
get_eo_images_mime_types
(payload: Dict) → Dict[str, List][source]¶ Get the accepted media-types from the deployment payload.
- Parameters
payload – Deploy payload.
- Returns
Accepted media-type.
-
weaver.processes.opensearch.
insert_max_occurs
(payload: Dict, wps_inputs: Dict[str, Deque]) → None[source]¶ Insert maxOccurs value in wps inputs using the deploy payload.
- Parameters
payload – Deploy payload.
wps_inputs – WPS inputs.