[Pywps-dev] Problem calling a WPS service from another WPS service

Jan Rudolf rudolja1 at fit.cvut.cz
Tue Jun 21 03:28:22 PDT 2016 

Hi Lorenzo, 

I am working on one description, how I use my forked PyWPS with Apache -
focused on Ubuntu. Would like to make a blog post this evening.

Cheers, Jan

On 2016-06-21 10:58, Lorenzo Bottaccioli wrote:
> Hi Jachym,
> 
> Is there any guide or suggestion to how set-up PyWPS4 with Apache2 or
> nginx? Do you think that I can use Cherrypy?
> 
> best,
> 
> Lorenzo
> 
> 2016-06-19 10:23 GMT+02:00 Jachym Cepicky <jachym.cepicky at gmail.com>:
> 
>> Hi Lorenzo,
>>
>> the problem could be that you use flask in single thread mode -
>> therefore it can handle only one request at time. [1] it should be
>> possible to switch to multihread mode, but consider for this case to
>> setup some real web server, like Apache2 or nginx
>>
>> J
>>
>> [1]
>>
> http://stackoverflow.com/questions/14814201/can-i-serve-multiple-clients-using-just-flask-app-run-as-standalone
>>
>> ne 19. 6. 2016 v 0:54 odesílatel Lorenzo Bottaccioli
>> <lorenzo.bottaccioli at gmail.com> napsal:
>>
>> Hi Jachym,
>>
>> Yes is using flask, I just ad process to the demo.py.
>>
>> Best, Lorenzo
>>
>> Il 18 giu 2016 11:40 PM, "Jachym Cepicky" <jachym.cepicky at gmail.com>
>> ha scritto:
>>
>> Lorenzo,
>>
>> are you using flask server or what WebServer are you using?
>>
>> J
>>
>> pá 10. 6. 2016 v 16:26 odesílatel Lorenzo Bottaccioli
>> <lorenzo.bottaccioli at gmail.com> napsal:
>>
>> Hi list,
>>
>> I'm having a problem with a service when I call another service
>> inside the process.
>>
>> def _handler(self, request, response):
>>
>> df = self.get_real_sky(geodf,start,end,model)
>>
>> def get_real_sky(self,geodf,start,end,model):
>> #print 'eccolo dentro'
>> import requests
>> url = "MAILSCANNER WARNING: NUMERICAL LINKS ARE OFTEN
>> MALICIOUS: http://130.192.5.114:8080/wps [1]"
>>
>> payload = "<wps:Execute service=\"WPS\" version=\"1.0.0\"
>> xmlns:wps=\"http://www.opengis.net/wps/1.0.0\ [2]"
>> xmlns:ows=\"http://www.opengis.net/ows/1.1\ [3]"
>> xmlns:xlink=\"http://www.w3.org/1999/xlink\ [4]"
>> xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\ [5]"
>>
> xsi:schemaLocation=\"http://www.opengis.net/wps/1.0.0\n../wpsExecute_request.xsd\
>> [6]">\n <ows:Identifier>real_sky</ows:Identifier>\n
>> <wps:DataInputs>\n    <wps:Input>\n
>> <ows:Identifier>layer_in</ows:Identifier>\n    <wps:Data>\n
>> <wps:ComplexData>"+geodf.to_json()+"</wps:ComplexData>\n
>> </wps:Data>\n    </wps:Input>\n    <wps:Input>\n
>> <ows:Identifier>start</ows:Identifier>\n        <wps:Data>\n
>> <wps:LiteralData
>> dataType=\"xs:string\">"+start+"</wps:LiteralData>\n
>> </wps:Data>\n    </wps:Input>\n    <wps:Input>\n
>> <ows:Identifier>end</ows:Identifier>\n        <wps:Data>\n
>> <wps:LiteralData dataType=\"xs:string\">"+end+"</wps:LiteralData>\n
>> </wps:Data>\n    </wps:Input>\n    <wps:Input>\n
>> <ows:Identifier>model</ows:Identifier>\n        <wps:Data>\n
>> <wps:LiteralData
>> dataType=\"xs:string\">"+model+"</wps:LiteralData>\n
>> </wps:Data>\n    </wps:Input>\n  </wps:DataInputs>\n
>> <wps:ResponseForm>\n    <wps:RawDataOutput>\n
>> <ows:Identifier>layer_out</ows:Identifier>\n
>> </wps:RawDataOutput>\n  </wps:ResponseForm>\n</wps:Execute>"
>>
>> headers = {
>> 'content-type': "application/xml",
>> 'cache-control': "no-cache",
>> 'postman-token': "78829681-df08-3317-2e0e-90a31ea4f2a6"
>> }
>>
>> response = requests.request("POST", url, data=payload,
>> headers=headers)
>>
>> return response.text
>>
>> The process inside def get_real_sky works if I call it by it self,
>> but if I call inside another process dosent work, it simply blocks
>> and do not go forward. I have tried to run only the service real_sky
>> in another port not in 8080 like the one who calls it but in 8082.
>> In this way it works. I dont understand if the problem is Flask or
>> the problem is PyWPS.
>>
>> If I press crtl+c to stop the process I get this:
>>
>> Exception happened during processing of request from
>> ('130.192.5.114', 49246)
>> Traceback (most recent call last):
>> File "/usr/lib/python2.7/SocketServer.py", line 295, in
>> _handle_request_noblock
>> self.process_request(request, client_address)
>> File "/usr/lib/python2.7/SocketServer.py", line 321, in
>> process_request
>> self.finish_request(request, client_address)
>> File "/usr/lib/python2.7/SocketServer.py", line 334, in
>> finish_request
>> self.RequestHandlerClass(request, client_address, self)
>> File "/usr/lib/python2.7/SocketServer.py", line 649, in __init__
>> self.handle()
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/serving.py",
>> line 216, in handle
>> rv = BaseHTTPRequestHandler.handle(self)
>> File "/usr/lib/python2.7/BaseHTTPServer.py", line 340, in handle
>> self.handle_one_request()
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/serving.py",
>> line 251, in handle_one_request
>> return self.run_wsgi()
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/serving.py",
>> line 193, in run_wsgi
>> execute(self.server.app)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/serving.py",
>> line 181, in execute
>> application_iter = app(environ, start_response)
>> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line
>> 1836, in __call__
>> return self.wsgi_app(environ, start_response)
>> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line
>> 1817, in wsgi_app
>> response = self.full_dispatch_request()
>> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line
>> 1478, in full_dispatch_request
>> response = self.make_response(rv)
>> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line
>> 1577, in make_response
>> rv = self.response_class.force_type(rv, request.environ)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/wrappers.py",
>> line 847, in force_type
>> response = BaseResponse(*_run_wsgi_app(response, environ))
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/wrappers.py",
>> line 57, in _run_wsgi_app
>> return _run_wsgi_app(*args)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/test.py",
>> line 871, in run_wsgi_app
>> app_rv = app(environ, start_response)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/Werkzeug-0.11.4-py2.7.egg/werkzeug/wrappers.py",
>> line 291, in application
>> return f(*args[:-2] + (request,))(*args[-2:])
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/pywps-4.0-py2.7.egg/pywps/app/Service.py",
>> line 529, in __call__
>> request_uuid
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/pywps-4.0-py2.7.egg/pywps/app/Service.py",
>> line 296, in execute
>> response = self._parse_and_execute(process, wps_request, uuid)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/pywps-4.0-py2.7.egg/pywps/app/Service.py",
>> line 358, in _parse_and_execute
>> wps_response = process.execute(wps_request, uuid)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/pywps-4.0-py2.7.egg/pywps/app/Process.py",
>> line 145, in execute
>> wps_response = self._run_process(wps_request, wps_response)
>> File
>>
> "/usr/local/lib/python2.7/dist-packages/pywps-4.0-py2.7.egg/pywps/app/Process.py",
>> line 151, in _run_process
>> wps_response = self.handler(wps_request, wps_response)
>> File
>>
> "/home/lorenzo/tools/pywps-4/pywps-4-demo/processes/solar/PV_NOCT.py",
>> line 45, in _handler
>> df = self.get_real_sky(geodf,start,end,model)
>> File
>>
> "/home/lorenzo/tools/pywps-4/pywps-4-demo/processes/solar/PV_NOCT.py",
>> line 101, in get_real_sky
>> response = requests.request("POST", url, data=payload,
>> headers=headers)
>> File "/usr/lib/python2.7/dist-packages/requests/api.py", line 44,
>> in request
>> return session.request(method=method, url=url, **kwargs)
>> File "/usr/lib/python2.7/dist-packages/requests/sessions.py", line
>> 455, in request
>> resp = self.send(prep, **send_kwargs)
>> File "/usr/lib/python2.7/dist-packages/requests/sessions.py", line
>> 558, in send
>> r = adapter.send(request, **kwargs)
>> File "/usr/lib/python2.7/dist-packages/requests/adapters.py", line
>> 330, in send
>> timeout=timeout
>> File "/usr/lib/python2.7/dist-packages/urllib3/connectionpool.py",
>> line 562, in urlopen
>> body=body, headers=headers)
>> File "/usr/lib/python2.7/dist-packages/urllib3/connectionpool.py",
>> line 414, in _make_request
>> httplib_response = conn.getresponse(buffering=True)
>> File "/usr/lib/python2.7/httplib.py", line 1051, in getresponse
>> response.begin()
>> File "/usr/lib/python2.7/httplib.py", line 415, in begin
>> version, status, reason = self._read_status()
>> File "/usr/lib/python2.7/httplib.py", line 371, in _read_status
>> line = self.fp.readline(_MAXLINE + 1)
>> File "/usr/lib/python2.7/socket.py", line 476, in readline
>> data = self._sock.recv(self._rbufsize)
>> KeyboardInterrupt
>> ----------------------------------------
>>
>> 130.192.5.114 - - [10/Jun/2016 16:25:45] "POST /wps HTTP/1.1" 200 -
>> INFO:werkzeug:130.192.5.114 - - [10/Jun/2016 16:25:45] "POST /wps
>> HTTP/1.1" 200 -
>> ----------------------------------------
>> Exception happened during processing of request from
>> ('130.192.5.114', 49248)
>> Traceback (most recent call last):
>> File "/usr/lib/python2.7/SocketServer.py", line 295, in
>> _handle_request_noblock
>> self.process_request(request, client_address)
>> File "/usr/lib/python2.7/SocketServer.py", line 321, in
>> process_request
>> self.finish_request(request, client_address)
>> File "/usr/lib/python2.7/SocketServer.py", line 334, in
>> finish_request
>> self.RequestHandlerClass(request, client_address, self)
>> File "/usr/lib/python2.7/SocketServer.py", line 651, in __init__
>> self.finish()
>> File "/usr/lib/python2.7/SocketServer.py", line 710, in finish
>> self.wfile.close()
>> File "/usr/lib/python2.7/socket.py", line 279, in close
>> self.flush()
>> File "/usr/lib/python2.7/socket.py", line 303, in flush
>> self._sock.sendall(view[write_offset:write_offset+buffer_size])
>> error: [Errno 32] Broken pipe
>> ----------------------------------------
>>
>> Any suggestion?
>>
>> Best,
>>
>> Lorenzo
>>
>> _______________________________________________
>> pywps-dev mailing list
>> pywps-dev at lists.osgeo.org
>> http://lists.osgeo.org/mailman/listinfo/pywps-dev
> 
>  
> 
> Links:
> ------
> [1] http://130.192.5.114:8080/wps
> [2] http://www.opengis.net/wps/1.0.0%5C
> [3] http://www.opengis.net/ows/1.1%5C
> [4] http://www.w3.org/1999/xlink%5C
> [5] http://www.w3.org/2001/XMLSchema-instance%5C
> [6] http://www.opengis.net/wps/1.0.0%5Cn../wpsExecute_request.xsd%5C
> _______________________________________________
> pywps-dev mailing list
> pywps-dev at lists.osgeo.org
> http://lists.osgeo.org/mailman/listinfo/pywps-dev

More information about the pywps-dev mailing list