data_field_dispose/data_mgo_to_tidb_project/nsq.go

package main

import (
	"encoding/json"
	"log"

	"data_mgo_to_tidb_project/config"

	"bp.jydev.jianyu360.cn/BP/jynsq/gonsq"
)

//异常告警
type AlertNsq struct {
	Addr   string
	Toppic string
	Id     string //用于标识这个告警分组，及告警方式、告警人
}

var AlertRemind AlertNsq

//Alert 异常告警通知
func Alert(msg string) {
	//自定义需要的字段
	errMap := map[string]interface{}{
		"异常": msg,
	}
	//nsq
	m := &gonsq.Msg{AlertRemind.Id, config.Conf.Alarm.Title, config.Conf.Alarm.Text, errMap}
	bs, _ := json.Marshal(m)
	p, _ := gonsq.NewProducer(AlertRemind.Addr, AlertRemind.Toppic, false) //测试环境地址
	err := p.Publish(bs)
	defer p.P.Stop()
	if err != nil {
		log.Println("nsq连接失败")
	}
}