In [2]:
import docker, json, os
import urllib.request
import requests
import rsplib as rsp
client = docker.DockerClient(base_url='http://triplewave1.westeurope.cloudapp.azure.com:2375')
In [3]:
for i in client.images.list():
print(i)
<Image: 'ubuntu:latest'>
<Image: 'streamreasoning/twcitybench:latest'>
<Image: 'streamreasoning/triplewave:rsplab'>
<Image: 'postgres:latest'>
<Image: 'openjdk:8'>
<Image: 'google/cadvisor:v0.24.0'>
In [4]:
client.containers.run("streamreasoning/twcitybench:latest", name="remote_stream",
command="running/AarhusParkingDataKALKVAERKSVEJ.properties",
ports={'4000/tcp': 4000, '4040/tcp': 4040},
volumes={'/home/rspdev/rsplab-benchmarks/benchmarks/citybench/triplewave': {'bind': '/opt/tw/running', 'mode': 'rw'}},
detach=True)
Out[4]:
<Container: 6fe6a08a92>
In [5]:
for c in client.containers.list():
print(c.name)
client.containers.list()
Out[5]:
[]
In [16]:
requests.get("http://triplewave1.westeurope.cloudapp.azure.com:4000/start")
---------------------------------------------------------------------------
RemoteDisconnected Traceback (most recent call last)
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, **response_kw)
594 body=body, headers=headers,
--> 595 chunked=chunked)
596
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in _make_request(self, conn, method, url, timeout, chunked, **httplib_request_kw)
392 # otherwise it looks like a programming error was the cause.
--> 393 six.raise_from(e, None)
394 except (SocketTimeout, BaseSSLError, SocketError) as e:
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/packages/six.py in raise_from(value, from_value)
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in _make_request(self, conn, method, url, timeout, chunked, **httplib_request_kw)
388 try:
--> 389 httplib_response = conn.getresponse()
390 except Exception as e:
/opt/conda/lib/python3.5/http/client.py in getresponse(self)
1196 try:
-> 1197 response.begin()
1198 except ConnectionError:
/opt/conda/lib/python3.5/http/client.py in begin(self)
296 while True:
--> 297 version, status, reason = self._read_status()
298 if status != CONTINUE:
/opt/conda/lib/python3.5/http/client.py in _read_status(self)
265 # sending a valid response.
--> 266 raise RemoteDisconnected("Remote end closed connection without"
267 " response")
RemoteDisconnected: Remote end closed connection without response
During handling of the above exception, another exception occurred:
ProtocolError Traceback (most recent call last)
/opt/conda/lib/python3.5/site-packages/requests/adapters.py in send(self, request, stream, timeout, verify, cert, proxies)
422 retries=self.max_retries,
--> 423 timeout=timeout
424 )
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, **response_kw)
639 retries = retries.increment(method, url, error=e, _pool=self,
--> 640 _stacktrace=sys.exc_info()[2])
641 retries.sleep()
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/util/retry.py in increment(self, method, url, response, error, _pool, _stacktrace)
260 if read is False:
--> 261 raise six.reraise(type(error), error, _stacktrace)
262 elif read is not None:
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/packages/six.py in reraise(tp, value, tb)
684 if value.__traceback__ is not tb:
--> 685 raise value.with_traceback(tb)
686 raise value
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, **response_kw)
594 body=body, headers=headers,
--> 595 chunked=chunked)
596
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in _make_request(self, conn, method, url, timeout, chunked, **httplib_request_kw)
392 # otherwise it looks like a programming error was the cause.
--> 393 six.raise_from(e, None)
394 except (SocketTimeout, BaseSSLError, SocketError) as e:
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/packages/six.py in raise_from(value, from_value)
/opt/conda/lib/python3.5/site-packages/requests/packages/urllib3/connectionpool.py in _make_request(self, conn, method, url, timeout, chunked, **httplib_request_kw)
388 try:
--> 389 httplib_response = conn.getresponse()
390 except Exception as e:
/opt/conda/lib/python3.5/http/client.py in getresponse(self)
1196 try:
-> 1197 response.begin()
1198 except ConnectionError:
/opt/conda/lib/python3.5/http/client.py in begin(self)
296 while True:
--> 297 version, status, reason = self._read_status()
298 if status != CONTINUE:
/opt/conda/lib/python3.5/http/client.py in _read_status(self)
265 # sending a valid response.
--> 266 raise RemoteDisconnected("Remote end closed connection without"
267 " response")
ProtocolError: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response',))
During handling of the above exception, another exception occurred:
ConnectionError Traceback (most recent call last)
<ipython-input-16-175d5c913950> in <module>()
1
----> 2 requests.get("http://triplewave1.westeurope.cloudapp.azure.com:4000/start")
/opt/conda/lib/python3.5/site-packages/requests/api.py in get(url, params, **kwargs)
68
69 kwargs.setdefault('allow_redirects', True)
---> 70 return request('get', url, params=params, **kwargs)
71
72
/opt/conda/lib/python3.5/site-packages/requests/api.py in request(method, url, **kwargs)
54 # cases, and look like a memory leak in others.
55 with sessions.Session() as session:
---> 56 return session.request(method=method, url=url, **kwargs)
57
58
/opt/conda/lib/python3.5/site-packages/requests/sessions.py in request(self, method, url, params, data, headers, cookies, files, auth, timeout, allow_redirects, proxies, hooks, stream, verify, cert, json)
473 }
474 send_kwargs.update(settings)
--> 475 resp = self.send(prep, **send_kwargs)
476
477 return resp
/opt/conda/lib/python3.5/site-packages/requests/sessions.py in send(self, request, **kwargs)
594
595 # Send the request
--> 596 r = adapter.send(request, **kwargs)
597
598 # Total elapsed time of the request (approximately)
/opt/conda/lib/python3.5/site-packages/requests/adapters.py in send(self, request, stream, timeout, verify, cert, proxies)
471
472 except (ProtocolError, socket.error) as err:
--> 473 raise ConnectionError(err, request=request)
474
475 except MaxRetryError as e:
ConnectionError: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response',))
In [46]:
requests.get("http://triplewave1.westeurope.cloudapp.azure.com:4000/sgraph").json()
Out[46]:
{'@context': {'generatedAt': {'@id': 'http://www.w3.org/ns/prov#generatedAtTime',
'@type': 'http://www.w3.org/2001/XMLSchema#dateTime'},
'sld': 'http://streamreasoning.org/ontologies/SLD4TripleWave#'},
'@id': 'tr:sGraph',
'sld:contains': {'@list': [{'@id': 'http://www.streamreasoning.org/ontologies/rsplab/citybench.owl#AarhusParkingDataKALKVAERKSVEJ/7-258dfa5e0bab4e220d77f4bfa88fe6dd',
'generatedAt': {'@type': 'http://www.w3.org/2001/XMLSchema#dateTime',
'@value': '2017-04-12T16:11:54.225+0000'}}]},
'sld:lastUpdated': {'@type': 'http://www.w3.org/2001/XMLSchema#dateTime',
'@value': '2017-04-12T16:11:54.225+0000'},
'sld:streamLocation': 'ws://triplewave1.westeurope.cloudapp.azure.com:4040/primus',
'sld:tBoxLocation': 'https://rsplab.blob.core.windows.net/static/citybench.owl'}
In [14]:
!docker ps
/bin/sh: 1: docker: not found
In [ ]:
Content source: riccardotommasini/rsplib
Similar notebooks: