init draft

Author: bennzhang

config.py

@@ -0,0 +1,12 @@
+'''
+  This is the config file which include all ccnfiguation info here
+'''
+
+_DB_CONF = {
+ 'host':'<YOUR-MYSQL-HOST>',
+ 'port':3306,
+ 'user':'<YOUR-MYSQL-USERNAME>',
+ 'passwd':'<YOUR-MYSQL-PASSWORD>',
+ 'db':'<YOUR-MYSQL-DATABASE>'
+}
+

gunicorn.conf.py

@@ -0,0 +1,28 @@
+#By default the multi-process version of the runtime is launched via the Gunicorn webserver and is configured to use gevent-based concurrency and a number of processes equal to the number of CPU cores available.
+
+#This can be changed by creating a file called gunicorn.conf.py in your applications root directory, which will override the default gunicorn.conf.py included with this project
+
+
+import multiprocessing
+
+# Use threaded workers. Thread-based concurrency is provided via the 'futures'
+# package. 'gevent' or other workers would be candidates, except that the ndb
+# library has its own concurrency model that conflicts with gevent and possibly
+# with similar approaches.
+worker_class = 'gthread'
+
+# Use a number of workers equal to the number of CPU cores available.
+# Reducing this number on a multicore instance will reduce memory consumption,
+# but will also reduce the app's ability to utilize all available CPU resources.
+workers = multiprocessing.cpu_count()
+#workers = 8 # good
+
+# Use an arbitrary number of threads for concurrency. This will dictate the
+# maximum number of requests handled concurrently by EACH worker.
+threads = 25
+
+# Settings specific to the Managed VMs production environment such as "bind"
+# and "logfile" are set in the Dockerfile's ENTRYPOINT directive.
+
+# Store the process ID of gunicorn.  Used for testing.
+pidfile = 'gunicorn_pid.txt'

main.py

@@ -0,0 +1,104 @@
+import logging
+
+from flask import Flask, request
+import datetime
+import decimal
+import pymysql
+import json
+import config
+from flask_cors import CORS
+
+app = Flask(__name__)
+
+"""
+CORS function is to avoid No 'Access-Control-Allow-Origin' error
+"""
+CORS(app)
+
+def type_handler(x):
+    """type Serialization function.
+
+    Args:
+        x:
+
+    Returns:
+        Serialization format of data, add more isinstance(x,type) if needed
+    """
+    if isinstance(x, datetime.datetime):
+        return x.isoformat()
+    if isinstance(x, decimal.Decimal):
+        return '$%.2f'%(x)
+    raise TypeError("Unknown type")
+
+def rows_to_json(cols,rows):
+    """type Serialization function.
+    Args:
+        cols: column descriptions
+        rows: sql query result rows
+
+    Returns:
+        Array of json string with combination of columns and rows
+        [
+          {"column0":row[0], "column1":row[1], "column2":row[2], .......},
+          {"column0":row[0], "column1":row[1], "column2":row[2], .......},
+          {"column0":row[0], "column1":row[1], "column2":row[2], .......},
+          {"column0":row[0], "column1":row[1], "column2":row[2], .......},
+          {"column0":row[0], "column1":row[1], "column2":row[2], .......}
+        ]
+    """
+    result = []
+    for row in rows:
+        data = dict(zip(cols, row))
+        result.append(data)
+    return json.dumps(result, default=type_handler)
+
+
+@app.route('/')
+def hello():
+    """webserice test method
+    """
+    return 'Welcome Mysql Flask Demo'
+
+@app.route('/test')
+def test_get():
+    """ mysql test webservice '/test'
+    """
+    # create mysql connection
+    conn = pymysql.connect(host=config._DB_CONF['host'], 
+                           port=config._DB_CONF['port'], 
+                           user=config._DB_CONF['user'], 
+                           passwd=config._DB_CONF['passwd'], 
+                           db=config._DB_CONF['db'])
+    cur = conn.cursor()
+    sql="<PUT YOUR MySQL QUERY HERE>"
+    cur.execute(sql)
+    
+    # get all column names
+    columns = [desc[0] for desc in cur.description]
+    # get all data
+    rows=cur.fetchall()
+    
+    # build json 
+    result = rows_to_json(columns,rows)
+    #print(result)
+    
+    cur.close()
+    conn.close()
+
+    return result
+	
+@app.errorhandler(500)
+def server_error(e):
+    logging.exception('An error occurred during a request.')
+    return """
+    An internal error occurred: <pre>{}</pre>
+    See logs for full stacktrace.
+    """.format(e), 500
+
+if __name__ == '__main__':
+    # This is used when running locally. Gunicorn is used to run the
+    #app.run(host='0.0.0.0', port=8080, debug=True, processes=4, threaded=True)
+    app.run(threaded=True,debug=True)
+    #app.run(host='127.0.0.1', port=8080, debug=True)
+## [END app]
+

requirement.txt

@@ -0,0 +1,5 @@
+simplejson
+pymysql
+Flask==0.10.1
+flask-cors
+gunicorn==19.6.0