Update to Tornado v.6, Python 3 and cleaning up

Author: DBProductions

.gitignore

@@ -1 +1,5 @@
+bin/
+include/
+lib/
+pyvenv.cfg
 .DS_Store

README.md

@@ -1,12 +1,12 @@
 # tornado-examples
 
-Different simple examples with Tornado V.4.2.  
+Different examples with Tornado 6.0.1 and Python 3.6.1.  
 
 [Webside](http://www.tornadoweb.org)
 
 ## Getting started
 
-Clone the `tornado-examples` repository, install the dependencies and use examples.
+Clone the repository, create a virtual environment and install the dependencies.
 
 ### Prerequisites
 
@@ -19,6 +19,11 @@ Clone the `tornado-examples` repository.
     $ git clone [email protected]:DBProductions/tornado-examples.git
     $ cd tornado-examples
 
+Create a virtual environment and activate it.  
+
+    $ python3 -m venv .
+    $ source bin/activate
+
 Install the dependencies.
 
      $ pip install -r requirements.txt

basics/application.py

@@ -1,24 +1,53 @@
-#!/usr/bin/env python
-""" application class example """
-
-import tornado.ioloop
 import tornado.web
+import tornado.ioloop
+from tornado.options import define, options
 
-PORT = 8888
+define("port", default=8888, help="application port", type=int)
 
 class MainHandler(tornado.web.RequestHandler):
     """ main request handler """
     def get(self):
         message = "You requested %s\n" % self.request.uri
+        self.set_header("Content-Type", "text/plain")    
         self.write(message)
 
+class JsonHandler(tornado.web.RequestHandler):
+    def set_default_headers(self):
+        self.set_header('Content-Type', 'application/json')
+
+    def convertReqBody(self, body):
+        data = {}
+        try:
+            data = json.loads(body)
+        except ValueError:
+            elements = urllib.unquote_plus(body).split("&")
+            for i in elements:
+                couple = i.split("=")
+                if len(couple) > 1:
+                    data[couple[0]] = couple[1]
+        return data
+
+    def get(self):
+        self.write({"response": "GET", "uri": self.request.uri})
+
+    def post(self):
+    	data = self.convertReqBody(self.request.body)
+    	data['timestamp'] = int(time.time())
+    	self.write({"response": "POST", "uri": self.request.uri, "data": data})
+
 class Application(tornado.web.Application):
     """" application class """
     def __init__(self):
-        handlers = [(r".*", MainHandler)]
-        settings = {}
+        handlers = [(r"/json.*", JsonHandler),
+                    (r".*", MainHandler)]
+        settings = {
+            "debug": True,
+            "autoreload": True,
+            "compress_response": True,
+            "cookie_secret": "secret123"
+        }
         tornado.web.Application.__init__(self, handlers, **settings)
 
 if __name__ == "__main__":
-    Application().listen(PORT)
+    Application().listen(options.port)
     tornado.ioloop.IOLoop.instance().start()

basics/asynchttpclient.py

@@ -1,14 +1,30 @@
-#!/usr/bin/env python
-""" blocking HTTP client example """
-
 import tornado.httpclient
 
-URL = "http://www.google.com/"
+URL = "http://www.dbproductions.de/"
+
+def http_request():
+    http_client = tornado.httpclient.HTTPClient()
+    try:
+        response = http_client.fetch(URL)
+    except Exception as e:
+        print("Error: %s" % e)
+    else:
+        print("Status Code: {}, Request Time: {}, Body Length: {}".format(response.code,
+                                                                          response.request_time,
+                                                                          len(response.body)))
 
-http_client = tornado.httpclient.HTTPClient()
+async def async_http_request():
+    http_client = tornado.httpclient.AsyncHTTPClient()
+    try:
+        response = await http_client.fetch(URL)
+    except Exception as e:
+        print("Error: %s" % e)
+    else:
+        print("Status Code: {}, Request Time: {}, Body Length: {}".format(response.code,
+                                                                          response.request_time,
+                                                                          len(response.body)))
 
-try:
-    response = http_client.fetch(URL)
-    print response.body
-except tornado.httpclient.HTTPError, e:
-    print "Error:", e
+# do a synchronous http request
+http_request()
+# do a asynchronous http request
+tornado.ioloop.IOLoop.current().run_sync(async_http_request)

basics/gen.py

@@ -1,16 +1,24 @@
-#!/usr/bin/env python
-""" non-blocking, single-threaded HTTP server """
-
-import tornado.httpserver
+import tornado.web
 import tornado.ioloop
+import tornado.httpserver
 
 PORT = 8888
 
-def handle_request(request):
-    message = "You requested %s\n" % request.uri
-    request.write("HTTP/1.1 200 OK\r\nContent-Length: %d\r\n\r\n%s" % (len(message), message))
-    request.finish()
+class MainHandler(tornado.web.RequestHandler):
+    """ main request handler """
+    def get(self):
+        message = "You requested %s\n" % self.request.uri
+        self.write(message)
+
+class Application(tornado.web.Application):
+    """" application class """
+    def __init__(self):
+        handlers = [(r".*", MainHandler)]
+        settings = {}
+        tornado.web.Application.__init__(self, handlers, **settings)
 
-http_server = tornado.httpserver.HTTPServer(handle_request)
-http_server.listen(PORT)
-tornado.ioloop.IOLoop.instance().start()
+if __name__ == "__main__":
+    app = Application()
+    http_server = tornado.httpserver.HTTPServer(app)
+    http_server.listen(PORT)
+    tornado.ioloop.IOLoop.instance().start()