# server.py
from flask import Flask, request, jsonify, render_template_string
import json
app = Flask(__name__)
# 存储告警数据的列表，最多存储5条
alerts = []
# HTML 页面模板
HTML_TEMPLATE = """
边缘告警平台
"""
@app.route('/', methods=['GET'])
def index():
"""Serve the main HTML page."""
return render_template_string(HTML_TEMPLATE)
@app.route('/api/alerts', methods=['GET'])
def get_alerts():
"""API endpoint to get the current list of alerts."""
return jsonify(alerts)
@app.route('/receive_alert', methods=['POST'])
def receive_alert():
"""
Endpoint to receive alert data from the edge platform.
Expects a JSON payload with the structure provided in the query.
"""
global alerts
try:
json_data = request.get_json()
if not json_data:
return jsonify({"error": "No JSON data provided"}), 400
data = json_data.get("data", {})
product_id = data.get("product_id", "")
event_picture_base64 = data.get("eventPicture", "")
event_time = data.get("eventTime", "")
new_alert = {
"product_id": product_id,
"eventPicture": event_picture_base64,
"eventTime": event_time
}
alerts.insert(0, new_alert)
alerts = alerts[:5]
print(f"Received alert: Type {product_id}, Time: {event_time}")
return jsonify({"status": "success", "message": "Alert received"}), 200
except Exception as e:
print(f"Error processing alert: {e}")
return jsonify({"error": "Internal server error"}), 500
if __name__ == '__main__':
app.run(host='0.0.0.0', port=5000, debug=True)