Deploy the trigger on the Production Centre

This Jupyter Notebook creates a Web Processing Service request on the Ellip Platform Deployer to deploy the trigger and its associated coordinators on the Production Centre.

• First do the imports of the Python libraries required

import os
import getpass
import lxml.etree as etree
import owslib
from owslib.wps import monitorExecution
from owslib.wps import WebProcessingService
from nbconvert.preprocessors import ExecutePreprocessor, CellExecutionError
import nbformat as nbf

• Load the data pipeline configuration

%store -r

nb_config = os.path.join('..', 'configuration.ipynb')

nb = nbf.read(nb_config, 4)

exec(nb['cells'][2]['source']) in globals(), locals()

trigger_queue = dict([('artifact_id', trigger_queue_artifact_id),
                      ('version', trigger_queue_version),
                      ('repository', repository),
                      ('folder', folder),
                      ('community', community)])


trigger_queue_process_id = '%s_%s_%s_%s' % (trigger_queue['community'].replace('-', '_'),
                                            trigger_queue['artifact_id'].replace('-', '_'),
                                            trigger_queue['artifact_id'].replace('-', '_'),
                                            trigger_queue['version'].replace('.', '_'))

• Connect to the WPS server and do a GetCapabilities request to list the available process:

wps_url = '%s/zoo-bin/zoo_loader.cgi' % deployer

wps = WebProcessingService(wps_url, verbose=False, skip_caps=True)

wps.getcapabilities()

deploy_process_available = False

for index, elem in enumerate(wps.processes):

    if 'TerradueDeployProcess' in elem.identifier:

        deploy_process_available = True

if deploy_process_available:
    print 'TerradueDeployProcess is available'
else:
    raise Exception('TerradueDeployProcess is not available')

• Select the TerradueDeployProcess process to submit a DescribeProcess request and list the inputs:

process_id = 'TerradueDeployProcess'

process = wps.describeprocess(process_id)

for data_input in process.dataInputs:
    print data_input.identifier

print '----'

for process_output in process.processOutputs:
    print process_output.identifier

• Build the Python dictionary with the inputs:
• Submit the Execute WPS request:

for trigger in [trigger_queue, trigger_pipe]:
    ows_context_url = '/%s/_applications/%s/%s/%s/%s-%s-application-context.xml' % (trigger['community'],
                                                                                    trigger['community'],
                                                                                    trigger['artifact_id'],
                                                                                    trigger['version'],
                                                                                    trigger['artifact_id'],
                                                                                    trigger['version'])
    print 'Deploying %s' % ows_context_url

    inputs = [('applicationPackage', ows_context_url),
              ('apikey', api_key),
              ('coordinator', 'True')]

    execution = owslib.wps.WPSExecution(url=wps.url)

    execution_request = execution.buildRequest(process_id,
                                               inputs,
                                               output=[('deployResult', False)])


    execution_response = execution.submitRequest(etree.tostring(execution_request))

    execution.parseResponse(execution_response)

    monitorExecution(execution)

    if execution.isSucceded():
        print 'Application %s deployed!' % trigger['artifact_id']
    else:
        print 'Application %s not deployed!' % trigger['artifact_id']

• Check the new WPS capabilities:

wps = WebProcessingService(wps_url, verbose=False, skip_caps=True)
wps.getcapabilities()

trigger_queue_deployed = False

for index, elem in enumerate(wps.processes):
    if elem.identifier == trigger_queue_process_id:
        trigger_queue_deployed = True


if trigger_queue_deployed:
    print 'Process %s deployed' % trigger_queue_process_id
else:
    raise Exception('Process %s not deployed' % trigger_queue_process_id)