data-api.py

from flask import Flask
from flask_restful import Resource, Api, reqparse
from influxdb import InfluxDBClient
from flask_cors import CORS, cross_origin

app = Flask(__name__)
api = Api(app)

CORS(app,resources={r"/*": {"origins": "*"}})
app.config['CORS_HEADERS'] = 'Content-Type'

client = InfluxDBClient('localhost', 8086, '', '', 'suricata')

class Index(Resource):
    def get(self):
        return {'message': 'OK'}

class List(Resource):
    def get(self):
        result = client.query('SELECT * FROM intrusion ORDER BY time DESC LIMIT 20;')
        return list(result.get_points())

class Stat(Resource):
    def get(self):
        src_ip = client.query('SELECT COUNT("src_ip") FROM "intrusion" GROUP BY "src_ip";').raw
        dest_ip = client.query('SELECT  COUNT("dest_ip") FROM "intrusion" GROUP BY "dest_ip";').raw
        src_country_name = client.query('SELECT COUNT("src_country_name") FROM "intrusion" GROUP BY "src_country_name";').raw
        dest_country_name = client.query('SELECT COUNT("dest_country_name") FROM "intrusion" GROUP BY "dest_country_name";').raw
        overtime = client.query('SELECT COUNT("src_ip") FROM "intrusion" GROUP BY time(15m);')	

        return {
            "src_ip":[{'src_ip':x['tags']['src_ip'],'value':x['values'][0][1]} for x in src_ip['series']],
            "dest_ip":[{'dest_ip':x['tags']['dest_ip'],'value':x['values'][0][1]} for x in dest_ip['series']],
            "src_country":[{'src_country':x['tags']['src_country_name'],'value':x['values'][0][1]} for x in src_country_name['series']],
            "dest_country":[{'dest_country':x['tags']['dest_country_name'],'value':x['values'][0][1]} for x in dest_country_name['series']],
            "time":list(overtime.get_points())
        }

api.add_resource(Index, '/')
api.add_resource(List, '/list')
api.add_resource(Stat, '/stat')
if __name__ == '__main__':
    app.run(host='0.0.0.0', port=8014)