Add more slides for AFPyro-BE training

.gitignore

@@ -0,0 +1,2 @@
+.idea
+pyvenv

README.md

@@ -16,3 +16,10 @@ jump to a specific page.
 
 Aaron Maxwell
 amax at redsymbol dot net
+
+## Contributors
+
+Ludovic Gasc (GMLudo)
+
+* https://twitter.com/GMLudo
+* https://github.com/GMLudo

examples/aiohttp_basic_server.py

@@ -0,0 +1,35 @@
+"""Basic http server with minimal setup"""
+import aiohttp
+import aiohttp.server
+
+import asyncio
+from urllib.parse import urlparse, parse_qsl
+from aiohttp.multidict import MultiDict
+
+
+class HttpRequestHandler(aiohttp.server.ServerHttpProtocol):
+
+    @asyncio.coroutine
+    def handle_request(self, message, payload):
+        response = aiohttp.Response(
+            self.writer, 200, http_version=message.version)
+        content = "<h1>It Works!</h1>"
+        bcontent = content.encode('utf-8')
+        response.add_header('Content-Type', 'text/html; charset=UTF-8')
+        response.add_header('Content-Length', str(len(bcontent)))
+        response.send_headers()
+        response.write(bcontent)
+        yield from response.write_eof()
+
+
+if __name__ == '__main__':
+    loop = asyncio.get_event_loop()
+    f = loop.create_server(
+        lambda: HttpRequestHandler(debug=True, keep_alive=75),
+        '0.0.0.0', '8080')
+    srv = loop.run_until_complete(f)
+    print('serving on', srv.sockets[0].getsockname())
+    try:
+        loop.run_forever()
+    except KeyboardInterrupt:
+        pass

examples/aiohttp_client.py

@@ -0,0 +1,20 @@
+#!/usr/bin/env python3
+
+import aiohttp
+import sys
+import asyncio
+
+@asyncio.coroutine
+def curl(url):
+    response = yield from aiohttp.request('GET', url)
+    print(repr(response))
+
+    chunk = yield from response.content.read()
+    print('Downloaded: %s' % len(chunk))
+
+    response.close()
+
+
+if __name__ == '__main__':
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(curl(sys.argv[1]))

examples/aiohttp_complete_server.py

@@ -0,0 +1,44 @@
+"""Basic http server with minimal setup"""
+import aiohttp
+import aiohttp.server
+
+import asyncio
+from urllib.parse import urlparse, parse_qsl
+from aiohttp.multidict import MultiDict
+
+
+class HttpRequestHandler(aiohttp.server.ServerHttpProtocol):
+
+    @asyncio.coroutine
+    def handle_request(self, message, payload):
+        response = aiohttp.Response(
+            self.writer, 200, http_version=message.version)
+        get_params = MultiDict(parse_qsl(urlparse(message.path).query))
+        if message.method == 'POST':
+            post_params = yield from payload.read()
+        else:
+            post_params = None
+        content = "<h1>It Works!</h1>"
+        if get_params:
+            content += "<h2>Get params</h2><p>" + str(get_params) + "</p>"
+        if post_params:
+            content += "<h2>Post params</h2><p>" + str(post_params) + "</p>"
+        bcontent = content.encode('utf-8')
+        response.add_header('Content-Type', 'text/html; charset=UTF-8')
+        response.add_header('Content-Length', str(len(bcontent)))
+        response.send_headers()
+        response.write(bcontent)
+        yield from response.write_eof()
+
+
+if __name__ == '__main__':
+    loop = asyncio.get_event_loop()
+    f = loop.create_server(
+        lambda: HttpRequestHandler(debug=True, keep_alive=75),
+        '0.0.0.0', '8080')
+    srv = loop.run_until_complete(f)
+    print('serving on', srv.sockets[0].getsockname())
+    try:
+        loop.run_forever()
+    except KeyboardInterrupt:
+        pass