#!/usr/bin/env python

 # -*- coding: utf-8 -*-

 # @Time    : 2018/8/21 10:40

 # @Author  : WangYue

 # @Site    :

 # @File    : alertor_uwsgi.py

 # @Software: PyCharm

 #加入环境变量避免程序报错

 import sys,os

 sys.path.append(os.path.dirname(os.path.dirname(__file__)))

 #引入wsgi模型，这里主要是弄一个简单的http模型来说明asyncio的简单使用

 from wsgiref.simple_server import make_server

 #引入asyncio

 import asyncio

 #引入其他可能的依赖

 from threading import Thread

 import json

 #引入本程序其他的内容，与asyncio无关是程序业务的其他部分

 from conf.alertor_conf import ALERTOR_CONFIG

 from model.alert_method_class import SendMail

 #定义一个运行asyncio loop 的线程，去单独运行它

 def start_loop(loop):

     asyncio.set_event_loop(loop)

     loop.run_forever()

 new_loop = asyncio.new_event_loop() #这个new_loop将会用于运行异步程序

 t = Thread(target=start_loop, args=(new_loop,))

 t.start() #利用多线程，额外起一个线程运行asyncio loop然后它在自身使用协程之类处异步处理业务

 #这是wsgi主业务程序，application是wsgi的入口程序，wsgi就规定了这么个函数名，这样写wsgi就认可它是入口了。传参也是wsgi的规定，第一个是环境，第二个是响应

 def application(env,start_res):

     res_headers=[('Content-type', 'text/plain')]

     if env["REQUEST_METHOD"]=='POST':

         # the environment variable CONTENT_LENGTH may be empty or missing

         try:

             if env['PATH_INFO'] != "/send_alert":

                 status = "404 func is not in use"

                 start_res(status, res_headers)

                 return [b"func is not in use"]

             request_body_size = int(env.get('CONTENT_LENGTH', 0))

             status = "200 OK"

             request_body = env['wsgi.input'].read(request_body_size)

             print("post_info -->", request_body.decode())

             r_body=json.loads(request_body.decode())

             #就这里一行代码，new_loop.call_soon_threadsafe(），告诉asyncio去运行第一个参数的函数名，后边的参数是被运行函数的传参，有多少就传参多少个，这是异步的，非阻塞的。

             new_loop.call_soon_threadsafe(SendMail.sendEmail,"Alertor Alarm level:"+r_body["level"]+"  server: "+r_body["server"],r_body)

             start_res(status,res_headers)

             return [b"ok send alert......."]

         except (ValueError):

             status = "404 json data not found key"

             request_body_size = 0

             start_res(status, res_headers)

             return [b"get post info faild"]

     else:

         status = "403 method error"

         start_res(status,res_headers)

         return [b'method error']

 # 1、只接受POST请求。数据为json格式，json中标记的，包括但不限于，包括的信息将会入库，其他信息，在告警时会一并发出

 # {

 #     "level":"high", #告警级别，"high","medium","info",这个可以在配置文件中配置，配置信息是个列表，有序的从左至右为["high","medium","info"],对应后续告警逻辑及post中json的本字段。

 #     "@timestamp":"",#告警时间

 #     "server":"",#告警源，可以是ip，主机名，服务名等可标识的

 #     "message":""#具体的告警信息

 # }

 # 2、根据json中的level自动选择告警途径，选择方式，在配置文件中的alert_method字典信息

 # 3、将告警内容，存储数据库，便于日后查询

 # 4、后续提供查询统计告警信息的方法

 if __name__=="__main__":

     wsgi_server=make_server(ALERTOR_CONFIG['bind_ip'],ALERTOR_CONFIG['port'],application)

     wsgi_server.serve_forever()