flask 使用示例

目录结构

示例代码：

import json
import time
from flask import Flask, request, render_template
import pika
app = Flask(__name__)

@app.route('/alert/', methods=['POST'])
def alert():
    data = request.get_json()
    pszMsg=data["pszMsg"]
    msg=str(pszMsg).split('\n')
    for m in msg:
        print(m)
    return data
@app.route('/alertmq/', methods=['GET'])
def get_alert_from_mq():
    # 建立连接
    userx = pika.PlainCredentials("admin", "admin")
    conn = pika.BlockingConnection(pika.ConnectionParameters("20.4.32.89", 5672, '/', credentials=userx))
    # 开辟管道
    channelx = conn.channel()
    #消息处理函数
    result=[]
    for message in channelx.consume("zabbix_alert_query", inactivity_timeout=1):
        # if self._is_interrupted:
        #     break

        method, properties, body = message
        if method != None:
            result.append(json.loads(body))
            channelx.basic_ack(delivery_tag=method.delivery_tag)
        else:
            channelx.close()
            conn.close()
            break
    print(result)
    return render_template('ac.html',data=result)