added sql database

Author: Shikha-code36

.gitignore

@@ -2,4 +2,7 @@
 *.log   
 # ignore cache
 __pycache__
-*.pyc
+*.pyc
+
+#ignore DB instance
+instance/

Procfile

@@ -0,0 +1,31 @@
+from flask import Flask
+from flask_caching import Cache
+from models import db
+from constant import *
+
+cache = Cache()
+
+def create_app():
+    app = Flask(__name__)
+    app.config['SQLALCHEMY_DATABASE_URI'] = SQLALCHEMY_DATABASE_URI
+    app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
+    db.init_app(app)
+
+    app.config['CACHE_TYPE'] = CACHE_TYPE
+    app.config['CACHE_REDIS_HOST'] = CACHE_REDIS_HOST
+    app.config['CACHE_REDIS_PORT'] = CACHE_REDIS_PORT
+    app.config['CACHE_DEFAULT_TIMEOUT'] = CACHE_DEFAULT_TIMEOUT
+
+    cache.init_app(app)
+
+    from app.setData import set_bp
+    from app.getData import getdata_bp
+    from app.location import locations
+    from app.getInfo import getinfo
+
+    app.register_blueprint(set_bp)
+    app.register_blueprint(getdata_bp)
+    app.register_blueprint(locations)
+    app.register_blueprint(getinfo)
+
+    return app

app.py

@@ -0,0 +1,14 @@
+from flask import Blueprint, jsonify
+from models import Data
+from app import cache
+
+getdata_bp = Blueprint('getdata_bp', __name__)
+
+@getdata_bp.route("/getdata/<int:device_fk_id>", methods=['GET'])
+@cache.cached(timeout=120, query_string=True)
+def getdata(device_fk_id):
+    data = Data.query.filter_by(device_fk_id=device_fk_id).order_by(
+        Data.time_stamp.desc()).first()
+    result = {'device_fk_id': data.device_fk_id, 'latitude': data.latitude, 'longitude': data.longitude,
+              'time_stamp': data.time_stamp.strftime('%Y-%m-%dT%H:%M:%SZ'), 'sts': data.sts, 'speed': data.speed}
+    return jsonify(result)

app/__init__.py

@@ -0,0 +1,19 @@
+from flask import Blueprint, jsonify, request
+from models import Data
+from datetime import datetime
+from app import cache
+
+getinfo = Blueprint('getinfo', __name__)
+
+@getinfo.route("/getinfo", methods=['GET'])
+@cache.cached(timeout=120, query_string=True)
+def getfulldata():
+    deviceId = request.args.get('deviceId')
+    start_time = request.args.get('starttime')
+    end_time = request.args.get('endtime')
+    formatted_start_time = datetime.strptime(start_time, '%Y-%m-%dT%H:%M:%SZ')
+    formatted_end_time = datetime.strptime(end_time, '%Y-%m-%dT%H:%M:%SZ')
+    data = Data.query.filter_by(device_fk_id=deviceId).filter(
+        Data.time_stamp >= formatted_start_time, Data.time_stamp <= formatted_end_time).order_by(Data.time_stamp.desc()).all()
+    result = [{'latitude': d.latitude, 'longitude': d.longitude, 'time_stamp': d.time_stamp.strftime('%Y-%m-%dT%H:%M:%SZ')} for d in data]
+    return jsonify(result)

app/getData.py

@@ -0,0 +1,21 @@
+from flask import Blueprint, jsonify, request
+from models import Data
+from datetime import datetime
+from app import cache
+
+locations = Blueprint('locations', __name__)
+
+@locations.route("/getlocation/<int:device_fk_id>", methods=['GET'])
+@cache.cached(timeout=120, query_string=True)
+def getlocdata():
+    deviceId = request.args.get('deviceId')
+    start_time = datetime.strptime(
+        request.args.get('starttime'), '%Y-%m-%dT%H:%M:%SZ')
+    end_time = datetime.strptime(
+        request.args.get('endtime'), '%Y-%m-%dT%H:%M:%SZ')
+    data = Data.query.filter_by(device_fk_id=deviceId).order_by(
+        Data.time_stamp.desc()).all()
+    result = [{'latitude': d.latitude, 'longitude': d.longitude, 'time_stamp': d.time_stamp.strftime('%Y-%m-%dT%H:%M:%SZ')}
+              for d in data if start_time <= d.time_stamp <= end_time]
+    return jsonify(result)
+

app/getInfo.py

@@ -0,0 +1,19 @@
+from flask import Blueprint, jsonify
+from models import db, Data
+from data import *
+from app import cache
+
+set_bp = Blueprint('set_bp', __name__)
+
+@set_bp.before_app_first_request
+def create_tables():
+    db.create_all()
+    populate_database_from_csv()
+
+@set_bp.route('/set', methods=['GET'])
+@cache.cached(timeout=120, query_string=True)
+def set():
+    data = Data.query.order_by(Data.sts.desc()).all()
+    result = [{'device_fk_id': d.device_fk_id, 'latitude': d.latitude, 'longitude': d.longitude,
+               'time_stamp': d.time_stamp.strftime('%Y-%m-%dT%H:%M:%SZ'), 'sts': d.sts, 'speed': d.speed} for d in data]
+    return jsonify(result)

app/location.py

@@ -0,0 +1,5 @@
+CACHE_TYPE = "redis"
+CACHE_REDIS_HOST="redis"
+CACHE_REDIS_PORT=6379
+CACHE_DEFAULT_TIMEOUT=600
+SQLALCHEMY_DATABASE_URI = 'sqlite:///data.db'

app/setData.py

@@ -0,0 +1,16 @@
+import csv
+from models import db, Data
+
+def populate_database_from_csv():
+    with open('utils/raw_data.csv') as csvfile:
+        reader = csv.DictReader(csvfile)
+        for row in reader:
+            device_fk_id = int(row['device_fk_id'])
+            latitude = float(row['latitude'])
+            longitude = float(row['longitude'])
+            time_stamp = row['time_stamp']
+            sts = True if row['sts'] == '1' else False
+            speed = float(row['speed'])
+            data = Data(device_fk_id, latitude, longitude, time_stamp, sts, speed)
+            db.session.add(data)
+    db.session.commit()

constant.py

@@ -0,0 +1,22 @@
+from datetime import datetime
+from flask_sqlalchemy import SQLAlchemy
+
+db = SQLAlchemy()
+
+class Data(db.Model):
+    __tablename__ = 'data'
+    id = db.Column(db.Integer, primary_key=True)
+    device_fk_id = db.Column(db.Integer)
+    latitude = db.Column(db.Float)
+    longitude = db.Column(db.Float)
+    time_stamp = db.Column(db.DateTime, default=datetime.utcnow)
+    sts = db.Column(db.Boolean)
+    speed = db.Column(db.Float)
+
+    def __init__(self, device_fk_id, latitude, longitude, time_stamp, sts, speed):
+        self.device_fk_id = device_fk_id
+        self.latitude = latitude
+        self.longitude = longitude
+        self.time_stamp = datetime.strptime(time_stamp, '%Y-%m-%dT%H:%M:%SZ')
+        self.sts = sts
+        self.speed = speed

data.py

@@ -0,0 +1,8 @@
+import os
+from app import create_app
+
+app = create_app()
+
+if __name__ == '__main__':
+    port = int(os.environ.get("PORT", 5000))
+    app.run(host='0.0.0.0', port=port)