编译安装最新版Grafana v6.6.0-pre

编译安装最新版Grafana v6.6.0-pre
–含企业微信告警及告警图片

安装go及node

版本需求：go1.13.3
node12.13.1
配置好$NODE_HOME、$GOROOT变量，请不要配置$GOPATH变量。具体配置请参阅其他资料。这里就不再赘述了。
检查输出：

[root@opstrip grafana]# go version
go version go1.13.3 linux/amd64
[root@opstrip grafana]# node -v
v12.13.1

编译安装Grafana

[root@opstrip ~]# cd /usr/local
[root@opstrip local]# git clone https://github.com/grafana/grafana.git     # 拉取grafana项目源码

添加企业微信告警模块

[root@opstrip local]# cd /usr/local/grafana/pkg/services/alerting/notifiers

分别将下面2个文件放入到该目录下：
wechat.go

package notifiers
    
import (
    "bytes"
    "encoding/json"
    "fmt"
    "io"
    "mime/multipart"
    "net/http"
    "os"
    "strconv"
    
    "golang.org/x/net/context"
    "golang.org/x/net/context/ctxhttp"
    
    "github.com/grafana/grafana/pkg/bus"
    "github.com/grafana/grafana/pkg/components/simplejson"
    "github.com/grafana/grafana/pkg/infra/log"
    m "github.com/grafana/grafana/pkg/models"
    "github.com/grafana/grafana/pkg/services/alerting"
)
    
type WeChatToken struct {
    AccessToken string `json:"access_token"`
    ErrMsg      string `json:"errmsg"`
    ErrCode     int    `json:"errcode"`
    ExpireIn    int    `json:"expire_in"`
}
    
type WeChatMediaId struct {
    MediaId string `json:"media_id"`
    ErrMsg  string `json:"errmsg"`
    ErrCode int    `json:"errcode"`
    CreatAt string `json:"created_at"`
    Type    string `json:"type"`
}
    
const (
    SEND_MESSAGE_ENDPOINT string = "https://qyapi.weixin.qq.com/cgi-bin/message/send"
    UPLOAD_IMAGE_ENDPOINT string = "https://qyapi.weixin.qq.com/cgi-bin/media/upload"
    GET_TOKEN_ENDPOINT    string = "https://qyapi.weixin.qq.com/cgi-bin/gettoken"
)
    
func init() {
    alerting.RegisterNotifier(&alerting.NotifierPlugin{
        Type:        "wechat",
        Name:        "WeChat",
        Description: "Sends HTTP POST request to WeChat",
        Factory:     NewWeChatNotifier,
        OptionsTemplate: `
      <h3 class="page-heading">WeChat settings</h3>
      <div class="gf-form">
        <span class="gf-form-label width-10">AgentId</span>
        <input type="text" required class="gf-form-input max-width-26" ng-model="ctrl.model.settings.agentid"></input>
      </div>
      <div class="gf-form">
        <span class="gf-form-label width-10">CorpId</span>
        <input type="text" required class="gf-form-input max-width-26" ng-model="ctrl.model.settings.corpid"></input>
      </div>
      <div class="gf-form">
        <span class="gf-form-label width-10">Secret</span>
        <input type="text" required class="gf-form-input max-width-26" ng-model="ctrl.model.settings.secret"></input>
      </div>
      <div class="gf-form">
        <span class="gf-form-label width-10">ToUser</span>
        <input type="text" required class="gf-form-input max-width-26" ng-model="ctrl.model.settings.touser"></input>
      </div>
    `,
    })
}
    
func NewWeChatNotifier(model *m.AlertNotification) (alerting.Notifier, error) {
    agentid := model.Settings.Get("agentid").MustString()
    if agentid == "" {
        return nil, alerting.ValidationError{Reason: "Could not find agentid property in settings"}
    }
    
    corpid := model.Settings.Get("corpid").MustString()
    if corpid == "" {
        return nil, alerting.ValidationError{Reason: "Could not find corpid property in settings"}
    }
    
    secret := model.Settings.Get("secret").MustString()
    if secret == "" {
        return nil, alerting.ValidationError{Reason: "Could not find secret property in settings"}
    }
    
    touser := model.Settings.Get("touser").MustString()
    if touser == "" {
        touser = "@all"
    }
    
    return &WeChatNotifier{
        NotifierBase: NewNotifierBase(model),
        AgentId:      agentid,
        CorpId:       corpid,
        Secret:       secret,
        ToUser:       touser,
        log:          log.New("alerting.notifier.wechat"),
    }, nil
}
    
type WeChatNotifier struct {
    NotifierBase
    AgentId string
    CorpId  string
    Secret  string
    ToUser  string
    log     log.Logger
}
    
func (this *WeChatNotifier) GetMediaId(path, token string) (string, error) {
    var mediaId string
    
    var b bytes.Buffer
    w := multipart.NewWriter(&b)
    
    f, err := os.Open(path)
    if err != nil {
        return mediaId, err
    }
    defer f.Close()
    
    fw, err := w.CreateFormFile("media", path)
    if err != nil {
        return mediaId, err
    }
    
    _, err = io.Copy(fw, f)
    if err != nil {
        return mediaId, err
    }
    w.Close()
    
    url := fmt.Sprintf(UPLOAD_IMAGE_ENDPOINT+"?access_token=%s&type=image", token)
    request, err := http.NewRequest(http.MethodPost, url, &b)
    if err != nil {
        return mediaId, err
    }
    
    request.Header.Add("Content-Type", w.FormDataContentType())
    request.Header.Add("User-Agent", "Grafana")
    
    resp, err := ctxhttp.Do(context.TODO(), http.DefaultClient, request)
    if err != nil {
        return mediaId, err
    }
    
    if resp.StatusCode/100 != 2 {
        return mediaId, fmt.Errorf("WeChat returned statuscode invalid status code: %v", resp.Status)
    }
    defer resp.Body.Close()
    
    var wechatMediaId WeChatMediaId
    err = json.NewDecoder(resp.Body).Decode(&wechatMediaId)
    if err != nil {
        return mediaId, err
    }
    
    if wechatMediaId.ErrCode != 0 {
        return mediaId, fmt.Errorf("WeChat returned errmsg: %s", wechatMediaId.ErrMsg)
    }
    
    return wechatMediaId.MediaId, nil
}
    
func (this *WeChatNotifier) GetAccessToken() (string, error) {
    var token string
    
    url := fmt.Sprintf(GET_TOKEN_ENDPOINT+"?corpid=%s&corpsecret=%s", this.CorpId, this.Secret)
    request, err := http.NewRequest(http.MethodPost, url, nil)
    if err != nil {
        return token, err
    }
    
    request.Header.Add("Content-Type", "application/json")
    request.Header.Add("User-Agent", "Grafana")
    
    resp, err := ctxhttp.Do(context.TODO(), http.DefaultClient, request)
    if err != nil {
        return token, err
    }
    
    if resp.StatusCode/100 != 2 {
        return token, fmt.Errorf("WeChat returned statuscode invalid status code: %v", resp.Status)
    }
    defer resp.Body.Close()
    
    var wechatToken WeChatToken
    err = json.NewDecoder(resp.Body).Decode(&wechatToken)
    if err != nil {
        return token, err
    }
    
    if wechatToken.ErrCode != 0 {
        return token, fmt.Errorf("WeChat returned errmsg: %s", wechatToken.ErrMsg)
    }
    return wechatToken.AccessToken, nil
}
    
func (this *WeChatNotifier) PushImage(evalContext *alerting.EvalContext, token string) error {
    mediaId, err := this.GetMediaId(evalContext.ImageOnDiskPath, token)
    if err != nil {
        return err
    }
    
    bodyJSON, err := simplejson.NewJson([]byte(`{
        "touser": "` + this.ToUser + `",
        "msgtype" : "image",
        "agentid": "` + this.AgentId + `",
        "image" : {
                "media_id": "` + mediaId + `"
        }
    }`))
    
    if err != nil {
        this.log.Error("Failed to create Json data", "error", err, "wechat", this.Name)
        return err
    }
    
    body, _ := bodyJSON.MarshalJSON()
    
    url := fmt.Sprintf(SEND_MESSAGE_ENDPOINT+"?access_token=%s", token)
    cmd := &m.SendWebhookSync{
        Url:  url,
        Body: string(body),
    }
    
    if err := bus.DispatchCtx(evalContext.Ctx, cmd); err != nil {
        this.log.Error("Failed to send WeChat", "error", err, "wechat", this.Name)
        return err
    }
    
    return nil
}
    
func (this *WeChatNotifier) Notify(evalContext *alerting.EvalContext) error {
    this.log.Info("Sending wechat")
    
    token, err := this.GetAccessToken()
    if err != nil {
        this.log.Error("Get AccessToken failed", err)
        return err
    }
    
    content := evalContext.GetNotificationTitle()
    content += "\\n\\n"
    
    if evalContext.Rule.State != m.AlertStateOK {
        content += "Message:\\n  " + evalContext.Rule.Message + "\\n\\n"
    }
    
    for index, evt := range evalContext.EvalMatches {
        if index == 0 {
            content += "Metric:\\n"
        }
        
        if index > 4 {
            content += "  ...\\n"
            break
        }
        content += "  " + evt.Metric + "=" + strconv.FormatFloat(evt.Value.Float64, 'f', -1, 64) + "\\n"
    }
    content += "\\n"
    
    if evalContext.Error != nil {
        content += "Error:\\n  " + evalContext.Error.Error() + "\\n\\n"
    }
    
    if evalContext.ImageOnDiskPath == "" && evalContext.ImagePublicURL != "" {
        content += "ImageUrl:\\n  " + evalContext.ImagePublicURL + "\\n"
    }
    
    bodyJSON, err := simplejson.NewJson([]byte(`{
        "touser": "` + this.ToUser + `",
        "msgtype" : "text",
        "agentid": "` + this.AgentId + `",
        "text" : {
                "content": "` + content + `"
        }
    }`))
    
    if err != nil {
        this.log.Error("Failed to create Json data", "error", err, "wechat", this.Name)
        return err
    }
    
    body, _ := bodyJSON.MarshalJSON()
    
    url := fmt.Sprintf(SEND_MESSAGE_ENDPOINT+"?access_token=%s", token)
    cmd := &m.SendWebhookSync{
        Url:  url,
        Body: string(body),
    }
    
    if err := bus.DispatchCtx(evalContext.Ctx, cmd); err != nil {
        this.log.Error("Failed to send WeChat", "error", err, "wechat", this.Name)
        return err
    }
    
    if evalContext.ImageOnDiskPath != "" {
        err := this.PushImage(evalContext, token)
        if err != nil {
            this.log.Error("Failed to Push Image", "error", err, "path", evalContext.ImageOnDiskPath)
        }
    }
    
    return nil
}

wechat_test.go

package notifiers
    
import (
    "testing"
    
    "github.com/grafana/grafana/pkg/components/simplejson"
    m "github.com/grafana/grafana/pkg/models"
    . "github.com/smartystreets/goconvey/convey"
)
    
func TestWeChatNotifier(t *testing.T) {
    Convey("WeChat notifier tests", t, func() {
        
        Convey("Parsing alert notification from settings", func() {
            Convey("empty settings should return error", func() {
                json := `{ }`
                
                settingsJSON, _ := simplejson.NewJson([]byte(json))
                model := &m.AlertNotification{
                    Name:     "wechat_testing",
                    Type:     "wechat",
                    Settings: settingsJSON,
                }
                
                _, err := NewWeChatNotifier(model)
                So(err, ShouldNotBeNil)
            })
            
            Convey("from settings with agentid, corpid, secret, touser", func() {
                json := `
                {
                    "agentid": "xxxx1",
                    "corpid": "####1",
                    "secret": "@@@@1",
                    "touser": "oooo1"
                }`
                
                settingsJSON, _ := simplejson.NewJson([]byte(json))
                model := &m.AlertNotification{
                    Name:     "wechat_testing",
                    Type:     "wechat",
                    Settings: settingsJSON,
                }
                
                not, err := NewWeChatNotifier(model)
                wechatNotifier := not.(*WeChatNotifier)
                
                So(err, ShouldBeNil)
                So(wechatNotifier.Name, ShouldEqual, "wechat_testing")
                So(wechatNotifier.Type, ShouldEqual, "wechat")
                So(wechatNotifier.AgentId, ShouldEqual, "xxxx1")
                So(wechatNotifier.CorpId, ShouldEqual, "####1")
                So(wechatNotifier.Secret, ShouldEqual, "@@@@1")
                So(wechatNotifier.ToUser, ShouldEqual, "oooo1")
            })
        })
    })
}

详见：https://github.com/wangriyu/docker-grafana ，以上文件有修改

构建后端

[root@opstrip notifiers]# cd /usr/local/grafana
[root@opstrip grafana]# go run build.go setup
[root@opstrip grafana]# go run build.go build

编译完成后的二进制文件如下：

[root@opstrip grafana]# pwd
/usr/local/grafana
[root@opstrip grafana]# ll bin/linux-amd64/
总用量 63952
-rwxr-xr-x 1 root root 19121704 11月 22 14:18 grafana-cli
-rw-r--r-- 1 root root       33 11月 22 14:18 grafana-cli.md5
-rwxr-xr-x 1 root root 46352720 11月 22 14:18 grafana-server
-rw-r--r-- 1 root root       33 11月 22 14:18 grafana-server.md5
[root@opstrip grafana]#

构建前端

[root@opstrip grafana]# npm install -g yarn
[root@opstrip grafana]# yum -y install bzip2
[root@opstrip grafana]# yarn install --pure-lockfile
[root@opstrip grafana]# npm run build

注意：这里可能会因为软件源及墙的问题导致的连接超时而出现依赖下载失败的问题，请根据报错更换为国内源或使用代理，更好的体验还是在国外机器上编译。机器要求至少有2GiB或以上的空闲内存。

尝试运行Grafana

[root@opstrip grafana]# bin/linux-amd64/grafana-server

若输出无报错则编译成功，否则请按错误提示逐一处理。

将Grafana服务化以便于管理

如果习惯了之前rpm安装的Grafana配置或者基于不影响编译环境的考虑，可以将编译的Grafana相应文件放到指定路径。以下操作仅供参考。
标准化Grafana：

[root@opstrip grafana]# pwd
/usr/local/grafana
[root@opstrip grafana]# groupadd grafana && useradd -d /usr/share/grafana -g grafana -s /sbin/nologin -c "grafana user" grafana
[root@opstrip grafana]# mkdir -p /usr/share/grafana/{conf,public,scripts,tools} /var/lib/grafana/{plugins,png} /etc/grafana
[root@opstrip grafana]# cp bin/linux-amd64/grafana-* /usr/sbin
[root@opstrip grafana]# rsync -avz conf/* /etc/grafana/
[root@opstrip grafana]# rsync -avz conf/* /usr/share/grafana/conf/
[root@opstrip grafana]# rsync -avz public/* /usr/share/grafana/public/
[root@opstrip grafana]# rsync -avz scripts/* /usr/share/grafana/scripts/
[root@opstrip grafana]# rsync -avz tools/* /usr/share/grafana/tools/
[root@opstrip grafana]# rsync -avz data/grafana.db /var/lib/grafana/
[root@opstrip grafana]# chmod -R grafana:grafana /usr/share/grafana /var/lib/grafana

grafana-server环境变量

[root@opstrip ~]# cat /etc/sysconfig/grafana-server 
GRAFANA_USER=grafana

GRAFANA_GROUP=grafana

GRAFANA_HOME=/usr/share/grafana

LOG_DIR=/var/log/grafana

DATA_DIR=/var/lib/grafana

MAX_OPEN_FILES=10000

CONF_DIR=/etc/grafana

CONF_FILE=/etc/grafana/grafana.ini

RESTART_ON_UPGRADE=true

PLUGINS_DIR=/var/lib/grafana/plugins

PROVISIONING_CFG_DIR=/etc/grafana/provisioning

# Only used on systemd systems
PID_FILE_DIR=/var/run/grafana

grafana.ini配置参考

[root@opstrip ~]# egrep -v "^#|^;|^$" /etc/grafana/grafana.ini 
app_mode = production
[paths]
data = /var/lib/grafana
temp_data_lifetime = 24h
logs = /var/log/grafana
plugins = /var/lib/grafana/plugins
provisioning = /etc/grafana/provisioning
[server]
protocol = http
http_addr =
http_port = 3000
domain = g.opstrip.com
root_url = http://g.opstrip.com/
serve_from_sub_path = false
router_logging = false
static_root_path = public
enable_gzip = false
socket = /var/run/grafana/grafana.sock
[database]
type = sqlite3
host = 127.0.0.1:3306
name = grafana
user = root
ssl_mode = disable
path = /var/lib/grafana/grafana.db
cache_mode = private
[remote_cache]
type = database
[dataproxy]
[analytics]
[security]
[snapshots]
[dashboards]
[users]
[auth]
[auth.anonymous]
[auth.github]
[auth.gitlab]
[auth.google]
[auth.grafananet]
[auth.grafana_com]
[auth.generic_oauth]
[auth.saml] # Enterprise only
[auth.basic]
[auth.proxy]
[auth.ldap]
[smtp]
enabled = true
host = mail.xxx.com:587
user = opstrip@xxx.com
password = **********
skip_verify = true
from_address = postmaster@xxx.com
from_name = opstrip
ehlo_identity = g.opstrip.com
[emails]
[log]
mode = console file
level = info
filters = rendering:debug
[log.console]
[log.file]
[log.syslog]
[quota]
[alerting]
enabled = true
execute_alerts = true
error_or_timeout = alerting
nodata_or_nullvalues = no_data
concurrent_render_limit = 5
evaluation_timeout_seconds = 30
notification_timeout_seconds = 30
max_attempts = 3
[explore]
[metrics]
[metrics.graphite]
[grafana_net]
[grafana_com]
[tracing.jaeger]
[external_image_storage]
[external_image_storage.s3]
[external_image_storage.webdav]
[external_image_storage.gcs]
[external_image_storage.azure_blob]
[external_image_storage.local]
[rendering]
server_url = http://localhost:8081/render
callback_url = http://localhost:3000/
[panels]
[plugins]
[enterprise]
[feature_toggles]

说明：[rendering]项是grafana-image-renderer插件的配置。[database]是Grafana使用的数据库，请根据需要选择MySQL或SQLite。[smtp]是发送邮件的配置，请根据实际情况填写。

使用systemd接管Grafana

[root@opstrip ~]# cat /usr/lib/systemd/system/grafana-server.service 
[Unit]
Description=Grafana instance
Documentation=http://docs.grafana.org
Wants=network-online.target
After=network-online.target
After=postgresql.service mariadb.service mysql.service

[Service]
EnvironmentFile=/etc/sysconfig/grafana-server
User=grafana
Group=grafana
Type=notify
Restart=on-failure
WorkingDirectory=/usr/share/grafana
RuntimeDirectory=grafana
RuntimeDirectoryMode=0750
ExecStart=/usr/sbin/grafana-server                                                  \
                            --homepath=${GRAFANA_HOME}                              \
                            --config=${CONF_FILE}                                   \
                            --pidfile=${PID_FILE_DIR}/grafana-server.pid            \
                            --packaging=build                                       \
                            cfg:default.paths.logs=${LOG_DIR}                       \
                            cfg:default.paths.data=${DATA_DIR}                      \
                            cfg:default.paths.plugins=${PLUGINS_DIR}                \
                            cfg:default.paths.provisioning=${PROVISIONING_CFG_DIR}  

LimitNOFILE=10000
TimeoutStopSec=20

[Install]
WantedBy=multi-user.target
[root@opstrip ~]# systemctl enable grafana-server.service
Created symlink from /etc/systemd/system/multi-user.target.wants/grafana-server.service to /usr/lib/systemd/system/grafana-server.service.
[root@opstrip ~]# systemctl start grafana-server.service
[root@opstrip ~]# ps -ef | grep grafana-server | grep -v grep
grafana   4746     1  0 12月03 ?      00:01:47 /usr/sbin/grafana-server --homepath=/usr/share/grafana --config=/etc/grafana/grafana.ini --pidfile=/var/run/grafana/grafana-server.pid --packaging=build cfg:default.paths.logs=/var/log/grafana cfg:default.paths.data=/var/lib/grafana cfg:default.paths.plugins=/var/lib/grafana/plugins cfg:default.paths.provisioning=/etc/grafana/provisioning
[root@opstrip ~]#

编译安装grafana-image-renderer图像渲染

### 安装`grafana-image-renderer`插件用于在告警中插入截图。
[root@opstrip grafana]# grafana-cli plugins install grafana-image-renderer        # 或者在plugins目录下直接拉取源码git clone https://github.com/grafana/grafana-image-renderer.git
[root@opstrip grafana]# echo "export GF_RENDERER_PLUGIN_IGNORE_HTTPS_ERRORS=true" >> /etc/profile && source /etc/profile
[root@opstrip grafana]# cd plugins/grafana-image-renderer/
[root@opstrip grafana]# make deps && make build_package ARCH=linux-x64-glibc
[root@opstrip grafana]# npm install -g node-pre-gyp node-gyp                      # 安装依赖
[root@opstrip grafana]# npm install                                               # 该操作会自动下载安装Chromium及grpc模块等
[root@opstrip grafana]# yarn install --pure-lockfile                              # 安装依赖
[root@opstrip grafana]# yarn run build                                            # 构建项目
[root@opstrip grafana]# node build/app.js server --port=8081                      # 测试启动。如有报错，请按报错逐一排除。一般是依赖问题。

说明：后台启动 /usr/bin/nohup /usr/local/node/bin/node /var/lib/grafana/plugins/grafana-image-renderer/build/app.js server --port=8081 &还可以用supervisord来管理grafana-image-renderer服务。
其他问题请参考：https://s0grafana0com.icopy.site/docs/administration/image_rendering/

配置企业微信告警

配置告警渠道Notification Channels

在左侧导航栏中依次选择Alerting→Notification Channels，在New channel新建告警渠道。选择Type为WeChat，选中Include image，再根据配置其他选项。如下图：

说明：关于AgentId、CorpId、Secret及ToUser请联系你的企业微信管理员获取。

在Dashboards中配置告警

在Dashboards→Panel→Edit→Alert中，配置相应的告警规则及阈值。如下图：

对上面几个字段的解释：

告警接收验证。
企业微信告警接收：

邮件告警接收：

可以看到，企微跟邮件都收到了带图片的告警截图。只是目前图片中出现中文的地方还是会显示乱码。也请知道怎么解决这个问题的小伙伴M我，谢谢

赏

谢谢您的支持

支付宝

微信