监控数据库字段 钉钉报警

package main
import (
 "bytes"
 "encoding/json"
 "fmt"
 _ "github.com/go-sql-driver/mysql"
 "github.com/go-xorm/xorm"
 "io/ioutil"
 "net/http"
 "time"
)
var engine *xorm.Engine
const webhook_url = "https://oapi.dingtalk.com/robot/send?access_token=xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
func dingtoinfo(s string) bool {
 content, data := make(map[string]string), make(map[string]interface{})
 content["content"] = s
 data["msgtype"] = "text"
 data["text"] = content
 b, _ := json.Marshal(data)
 resp, err := http.Post(webhook_url,
 "application/json",
 bytes.NewBuffer(b))
 if err != nil {
 fmt.Println(err)
 }
 defer resp.Body.Close()
 body, _ := ioutil.ReadAll(resp.Body)
 fmt.Println(string(body))
 return true
}
func recoverName() {
 if r := recover(); r != nil {
 res := fmt.Sprintf("%s %s", "监控程序 报错:", r)
 dingtoinfo(res)
 }
}
func main() {
 defer recoverName()
 var err error
 engine, err = xorm.NewEngine("mysql", "root:xxxxxxxxxxxxxxx@tcp(127.0.0.1:3306)/new?charset=utf8")
 if err != nil {
 panic(err.Error())
 }
 gsql := " select up_time from token where type = 0 ;"
 gres, gerr := engine.Query(gsql)
 if gerr != nil {
 panic(gerr.Error())
 }
 var data string
 for _, v := range gres {
 data = string(v["up_time"])
 }
 loc, _ := time.LoadLocation("Asia/Shanghai")
 nowTime := time.Now().In(loc)
 tm, _ := time.Parse("2006年01月02日 03:04:05", data)
 ntm := tm.In(loc)
 subM := nowTime.Sub(ntm)
 fmt.Println("token更新时间 与 系统时间 相差",subM)
 subtract := int(subM.Minutes())
 if subtract > 20 {
 dingtoinfo("异常, 请及时登录查看 !!!")
 }
}

本文来自:51CTO博客

感谢作者:295631788

查看原文:年轻人的第一个go程序:监控数据库字段 报警

• 编辑
• 预览