is-enes » impactportal

#!/bin/python

"""

Obtain an access token:

- Login with a google account at https://climate4impact.eu/impactportal/account/OAuth2.jsp 

- Generate via https://climate4impact.eu/impactportal/tokenapi?service=account&request=generatetoken

- Copy paste the accesstoken value in the "token" variable below.

Author: Maarten Plieger, KNMI, 2016-10-04

"""

token="put_your_access_token_here" # without a correct access token only public services do work, like this one.

wpsendpoint="https://climate4impact.eu/impactportal/WPS/"+token+"/?"

inputa=11;

inputb=22;

operator="divide" # Any of add, substract, multiply, divide

print "Calculating ["+str(inputa)+" "+str(operator)+" "+str(inputb)+"]"

import xml.etree.ElementTree as et

import urllib2

import time

from StringIO import StringIO

""" Parses URL to XML tree """

def getandparsexml(url):

  response = urllib2.urlopen(url)

  html = response.read()

  it = et.iterparse(StringIO(html))

  for _, el in it:

      if '}' in el.tag:

          el.tag = el.tag.split('}', 1)[1]  # strip all namespaces

  root = it.root

  return root

# Execute the ultimatequestionprocess aynchronousely and obtain the statusLocation for progress

datainputs = "inputa="+str(inputa)+";inputb="+str(inputb)+";operator="+str(operator)

root = getandparsexml(wpsendpoint+"service=WPS&version=1.0.0&request=execute&storeExecuteResponse=true&status=true&identifier=binaryoperatorfornumbers_10sec&datainputs="+datainputs)    

monitorURL = root.attrib['statusLocation']

print "Process executed checking " +monitorURL

# Get starttime of process, sometimes the monitorURL is not immediately available. Iterate until a valid creationtime is available would be good practice.

numberOfTries=10

while numberOfTries>0:

  numberOfTries = numberOfTries-1 

  try:

    root = getandparsexml(monitorURL)

    numberOfTries = -1

    print "Process started at "+str(root[1].attrib['creationTime'])

  except:

    time.sleep(1)

    pass

# Wait for process accepted to pass...

ProcessAcceptedFound = True

while ProcessAcceptedFound == True:

  root = getandparsexml(monitorURL)

  ProcessAcceptedFound = False

  for elem in root.iter(tag="ProcessAccepted"):

    ProcessAcceptedFound = True;

    print elem.tag, elem.attrib

  time.sleep(1)

# Now Monitor progress, polling the statuslocation frequently

percentage = 0

while percentage<100:

  root = getandparsexml(monitorURL)

  try:

    for elem in root.iter(tag="ProcessStarted"):

      percentage = float(elem.attrib['percentCompleted'])

    for elem in root.iter(tag="ProcessSucceeded"):

      percentage = 100

      break

  except:

    percentage=100.0

    pass

  print "Progress: "+str(percentage)+ " complete."

  time.sleep(1)

# Obtain the answer  

root = getandparsexml(monitorURL)

try:

  print "The answer for ["+str(inputa)+" "+str(operator)+" "+str(inputb)+"] is "+(root[2][0][2][0].text)

except:

  print "Processing failed: "+root[1][0][0][0][0].text

  pass