编写一个简单的 rtc_exporter

pigness · · 996 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

  1. 系统交互图


    rtc_exporter.png

1)rtc_server 通过写文件的方式将系统和业务数据记录到临时文件
2)rtc_exporter 读取相关配置并上传到 pushgateway

  1. 系统使用的是 golang 语言进行编写
    main.go
package main

import (
    "flag"
    "fmt"
    "os"
    "rtc_exporter/common"
    "rtc_exporter/structure"
    "rtc_exporter/utils"
    "time"

    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/push"
)

var (
    confFile = flag.String("c", "./config/config.json", "configuration file,json format")

    rtcData = prometheus.NewGaugeVec(prometheus.GaugeOpts{
        Name:      "rtc_server",
        Namespace: "rtc_server",
        Help:      "rtc server report running manually~",
    }, []string{"server", "key"})
)

//读取程序配置文件
func ReadConfigFile() (string, string, string, float64) {

    common.ProcessOptions()
    if err := common.LoadConfigFromFile(*confFile); err != nil {
        fmt.Println("Load Config File fail,", err)
        return "", "", "", -1
    }
    common.DumpConfigContent()

    // 获取日志配置
    expo_dest, err := common.GetConfigByKey("exporter.dest")
    if err != nil {
        fmt.Println("can not get dest config:", err)
        return "", "", "", -1
    }
    jobname, err := common.GetConfigByKey("exporter.jobname")
    if err != nil {
        fmt.Println("can not get jobname config:", err)
        return "", "", "", -1
    }
    filename, err := common.GetConfigByKey("exporter.filename")
    if err != nil {
        fmt.Println("can not get filename config:", err)
        return "", "", "", -1
    }
    interval, err := common.GetConfigByKey("exporter.interval")
    if err != nil {
        fmt.Println("can not get interval config:", err)
        return "", "", "", -1
    }

    return expo_dest.(string), jobname.(string), filename.(string), interval.(float64)
}

//main函数
func main() {

    var f func()
    var t *time.Timer

    expo_dest, jobname, filename, interval := ReadConfigFile()

    f = func() {
        var info structure.BasicInfo
        info, err := utils.ReadLineJson(filename, utils.ProcessLine)
        if err != nil {
            fmt.Println("Info error!")
        } else {
            registry := prometheus.NewRegistry()
            registry.MustRegister(rtcData)
            pusher := push.New(expo_dest, jobname).Gatherer(registry)

            rtcData.WithLabelValues(info.Server, "user").Set((float64)(info.Data.User))
            rtcData.WithLabelValues(info.Server, "qps").Set((float64)(info.Data.Qps))

            if err := pusher.Add(); err != nil {
                fmt.Println("Could not push to Pushgateway:", err)
                os.Exit(-1)
            }

            fmt.Println("success")
        }
        t = time.AfterFunc(time.Duration(interval)*time.Second, f)
    }

    t = time.AfterFunc(time.Duration(interval)*time.Second, f)

    defer t.Stop()
    time.Sleep(time.Minute)
}

因为是Beta版,只实现基本功能,后续会持续优化

  1. 实现功能:
    1)读取临时文件(json格式)
    2)读取配置文件信息(包括上报地址、间隔时间等)
    3)定时发送信息到 pushgateway

  2. 后续可优化的点
    1)改造成直接与 prometheus 交互的版本
    2)实现自身的高可用,守护进程等方式
    3)代码整合结构化...


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:pigness

查看原文:编写一个简单的 rtc_exporter

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

996 次点击  
加入收藏 微博
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传