通過Exporter收集一切指標(biāo)

作者：沒有文案的夏老師 2021-09-01 07:21:39

[[420791]]

本文轉(zhuǎn)載自微信公眾號「運(yùn)維開發(fā)故事」，作者沒有文案的夏老師。轉(zhuǎn)載本文請聯(lián)系運(yùn)維開發(fā)故事公眾號。

Exporter介紹

Exporter 是一個采集監(jiān)控數(shù)據(jù)并通過 Prometheus 監(jiān)控規(guī)范對外提供數(shù)據(jù)的組件，它負(fù)責(zé)從目標(biāo)系統(tǒng)(Your 服務(wù))搜集數(shù)據(jù)，并將其轉(zhuǎn)化為 Prometheus 支持的格式。Prometheus 會周期性地調(diào)用 Exporter 提供的 metrics 數(shù)據(jù)接口來獲取數(shù)據(jù)。那么使用 Exporter 的好處是什么?舉例來說，如果要監(jiān)控 Mysql/Redis 等數(shù)據(jù)庫，我們必須要調(diào)用它們的接口來獲取信息(前提要有)，這樣每家都有一套接口，這樣非常不通用。所以 Prometheus 做法是每個軟件做一個 Exporter，Prometheus 的 Http 讀取 Exporter 的信息(將監(jiān)控指標(biāo)進(jìn)行統(tǒng)一的格式化并暴露出來)。簡單類比，Exporter 就是個翻譯，把各種語言翻譯成一種統(tǒng)一的語言。

對于Exporter而言，它的功能主要就是將數(shù)據(jù)周期性地從監(jiān)控對象中取出來進(jìn)行加工，然后將數(shù)據(jù)規(guī)范化后通過端點(diǎn)暴露給Prometheus，所以主要包含如下3個功能。

封裝功能模塊獲取監(jiān)控系統(tǒng)內(nèi)部的統(tǒng)計信息。
將返回數(shù)據(jù)進(jìn)行規(guī)范化映射，使其成為符合Prometheus要求的格式化數(shù)據(jù)。
Collect模塊負(fù)責(zé)存儲規(guī)范化后的數(shù)據(jù)，最后當(dāng)Prometheus定時從Exporter提取數(shù)據(jù)時，Exporter就將Collector收集的數(shù)據(jù)通過HTTP的形式在/metrics端點(diǎn)進(jìn)行暴露。

介紹Primetheus client

本文將介紹Primetheus client的使用，基于golang語言，golang client 是當(dāng)pro收集所監(jiān)控的系統(tǒng)的數(shù)據(jù)時，用于響應(yīng)pro的請求，按照一定的格式給pro返回數(shù)據(jù)，說白了就是一個http server，源碼參見github,相關(guān)的文檔參見GoDoc,讀者可以直接閱讀文檔進(jìn)行開發(fā)，本文只是幫助理解。以下是簡化流程圖：

四種數(shù)據(jù)類型

prometheus將所有數(shù)據(jù)保存為timeseries data，用metric name和label區(qū)分，label是在metric name上的更細(xì)維度的劃分，其中的每一個實(shí)例是由一個float64和timestamp組成，只不過timestamp是隱式加上去的，有時候不會顯示出來。如下面所示(數(shù)據(jù)來源于prometheus暴露的監(jiān)控數(shù)據(jù)，訪問http://localhost:9090/metrics 可得)，其中g(shù)o_gc_duration_seconds是metrics name,quantile="0.5"是key-value pair的label，而后面的值是float64 value。

# HELP go_gc_duration_seconds A summary of the GC invocation durations. 
# TYPE go_gc_duration_seconds summary 
go_gc_duration_seconds{quantile="0.5"} 0.000107458 
go_gc_duration_seconds{quantile="0.75"} 0.000200112 
go_gc_duration_seconds{quantile="1"} 0.000299278 
go_gc_duration_seconds_sum 0.002341738 
go_gc_duration_seconds_count 18 
# HELP go_goroutines Number of goroutines that currently exist. 
# TYPE go_goroutines gauge 
go_goroutines 107

這些信息有一個共同點(diǎn)，就是采用了不同于JSON或者Protocol Buffers的數(shù)據(jù)組織形式——文本形式。在文本形式中，每個指標(biāo)都占用一行，#HELP代表指標(biāo)的注釋信息，#TYPE用于定義樣本的類型注釋信息，緊隨其后的語句就是具體的監(jiān)控指標(biāo)(即樣本)。#HELP的內(nèi)容格式如下所示，需要填入指標(biāo)名稱及相應(yīng)的說明信息。

HELP <metrics_name> <doc_string>

#TYPE的內(nèi)容格式如下所示，需要填入指標(biāo)名稱和指標(biāo)類型(如果沒有明確的指標(biāo)類型，需要返回untyped)。

TYPE <metrics_name> <metrics_type>

監(jiān)控樣本部分需要滿足如下格式規(guī)范。

metric_name [ "{" label_name "=" " label_value " { "," label_name "=" " label_value " } [ "," ] "}" ] value [ timestamp ]

其中，metric_name和label_name必須遵循PromQL的格式規(guī)范。value是一個f loat格式的數(shù)據(jù)，timestamp的類型為int64(從1970-01-01 00：00：00開始至今的總毫秒數(shù))，可設(shè)置其默認(rèn)為當(dāng)前時間。具有相同metric_name的樣本必須按照一個組的形式排列，并且每一行必須是唯一的指標(biāo)名稱和標(biāo)簽鍵值對組合。Prometheus為了方便client library的使用提供了四種數(shù)據(jù)類型：

Counter：Counter是一個累加的數(shù)據(jù)類型。一個Counter類型的指標(biāo)只會隨著時間逐漸遞增(當(dāng)系統(tǒng)重啟的時候，Counter指標(biāo)會被重置為0)。記錄系統(tǒng)完成的總?cè)蝿?wù)數(shù)量、系統(tǒng)從最近一次啟動到目前為止發(fā)生的總錯誤數(shù)等場景都適合使用Counter類型的指標(biāo)。

Gauge：Gauge指標(biāo)主要用于記錄一個瞬時值，這個指標(biāo)可以增加也可以減少，比如CPU的使用情況、內(nèi)存使用量以及硬盤當(dāng)前的空間容量等。
Histogram：Histogram表示柱狀圖，主要用于統(tǒng)計一些數(shù)據(jù)分布的情況，可以計算在一定范圍內(nèi)的數(shù)據(jù)分布情況，同時還提供了指標(biāo)值的總和。在大多數(shù)情況下，用戶會使用某些指標(biāo)的平均值作為參考，例如，使用系統(tǒng)的平均響應(yīng)時間來衡量系統(tǒng)的響應(yīng)能力。這種方式有個明顯的問題——如果大多數(shù)請求的響應(yīng)時間都維持在100ms內(nèi)，而個別請求的響應(yīng)時間需要1s甚至更久，那么響應(yīng)時間的平均值體現(xiàn)不出響應(yīng)時間中的尖刺，這就是所謂的“長尾問題”。為了更加真實(shí)地反映系統(tǒng)響應(yīng)能力，常用的方式是按照請求延遲的范圍進(jìn)行分組，例如在上述示例中，可以分別統(tǒng)計響應(yīng)時間在[0，100ms]、[100，1s]和[1s，∞]這3個區(qū)間的請求數(shù)，通過查看這3個分區(qū)中請求量的分布，就可以比較客觀地分析出系統(tǒng)的響應(yīng)能力。
Summary：Summary與Histogram類似，也會統(tǒng)計指標(biāo)的總數(shù)(以_count作為后綴)以及sum值(以_sum作為后綴)。兩者的主要區(qū)別在于，Histogram指標(biāo)直接記錄了在不同區(qū)間內(nèi)樣本的個數(shù)，而Summary類型則由客戶端計算對應(yīng)的分位數(shù)。例如下面展示了一個Summary類型的指標(biāo)，其中quantile=”0.5”表示中位數(shù)，quantile=”0.9”表示九分位數(shù)。

廣義上講，所有可以向Prometheus提供監(jiān)控樣本數(shù)據(jù)的程序都可以被稱為一個Exporter，Exporter的一個實(shí)例被稱為target，Prometheus會通過輪詢的形式定期從這些target中獲取樣本數(shù)據(jù)。

自己動手編寫一個Exporter

一般來說，絕大多數(shù)Exporter都是基于Go語言編寫的，一小部分是基于Python語言編寫的，還有很小一部分是使用Java語言編寫的。比如官方提供的Consul Metrics自定義采集器Exporter，如果是在Go語言的運(yùn)行環(huán)境下，需要按照如下所示代碼運(yùn)行這個Exporter。

package main 
  
import ( 
    "log" 
    "net/http" 
  
    "github.com/prometheus/client_golang/prometheus" 
    "github.com/prometheus/client_golang/prometheus/promhttp" 
) 
  
var ( 
    cpuTemp = prometheus.NewGauge(prometheus.GaugeOpts{ 
        NameSpace: "our_idc", 
        Subsystem: "k8s" 
        Name: "cpu_temperature_celsius", 
        Help: "Current temperature of the CPU.", 
    }) 
    hdFailures = prometheus.NewCounterVec( 
        prometheus.CounterOpts{ 
            NameSpace: "our_idc", 
            Subsystem: "k8s" 
            Name: "hd_errors_total", 
            Help: "Number of hard-disk errors.", 
        }, 
        []string{"device"}, 
    ) 
) 
  
func init() { 
    // Metrics have to be registered to be exposed: 
    prometheus.MustRegister(cpuTemp) 
    prometheus.MustRegister(hdFailures) 
} 
  
func main() { 
    cpuTemp.Set(65.3) 
    hdFailures.With(prometheus.Labels{"device":"/dev/sda"}).Inc() 
  
    // The Handler function provides a default handler to expose metrics 
    // via an HTTP server. "/metrics" is the usual endpoint for that. 
    http.Handle("/metrics", promhttp.Handler()) 
    log.Fatal(http.ListenAndServe(":8888", nil))

其中創(chuàng)建了一個gauge和CounterVec對象，并分別指定了metric name和help信息，其中CounterVec是用來管理相同metric下不同label的一組Counter，同理存在GaugeVec，可以看到上面代碼中聲明了一個lable的key為“device”，使用的時候也需要指定一個lable: hdFailures.With(prometheus.Labels{"device":"/dev/sda"}).Inc()。變量定義后進(jìn)行注冊，最后再開啟一個http服務(wù)的8888端口就完成了整個程序，Prometheus采集數(shù)據(jù)是通過定期請求該服務(wù)http端口來實(shí)現(xiàn)的。啟動程序之后可以在web瀏覽器里輸入http://localhost:8888/metrics 就可以得到client暴露的數(shù)據(jù)，其中有片段顯示為：

# HELP our_idc_k8s_cpu_temperature_celsius Current temperature of the CPU. 
# TYPE our_idc_k8s_cpu_temperature_celsius gauge 
our_idc_k8s_cpu_temperature_celsius 65.3 
# HELP our_idc_k8s_hd_errors_total Number of hard-disk errors. 
# TYPE our_idc_k8s_hd_errors_total counter 
our_idc_k8s_hd_errors_total{device="/dev/sda"} 1

上圖就是示例程序所暴露出來的數(shù)據(jù)，并且可以看到counterVec是有l(wèi)abel的,而單純的gauage對象卻不用lable標(biāo)識，這就是基本數(shù)據(jù)類型和對應(yīng)Vec版本的差別。此時再查看http://localhost:9090/graph 就會發(fā)現(xiàn)服務(wù)狀態(tài)已經(jīng)變?yōu)閁P了。上面的例子只是一個簡單的demo,因?yàn)樵趐rometheus.yml配置文件中我們指定采集服務(wù)器信息的時間間隔為60s，每隔60s Prometheus會通過http請求一次自己暴露的數(shù)據(jù)，而在代碼中我們只設(shè)置了一次gauge變量cupTemp的值，如果在60s的采樣間隔里將該值設(shè)置多次，前面的值就會被覆蓋，只有Prometheus采集數(shù)據(jù)那一刻的值能被看到，并且如果不再改變這個值，Prometheus就始終能看到這個恒定的變量，除非用戶顯式通過Delete函數(shù)刪除這個變量。使用Counter,Gauage等這些結(jié)構(gòu)比較簡單，但是如果不再使用這些變量需要我們手動刪，我們可以調(diào)用resetfunction來清除之前的metrics。

自定義Collector

直接使用Collector，go client Colletor只會在每次響應(yīng)Prometheus請求的時候才收集數(shù)據(jù)。需要每次顯式傳遞變量的值，否則就不會再維持該變量，在Prometheus也將看不到這個變量。Collector是一個接口，所有收集metrics數(shù)據(jù)的對象都需要實(shí)現(xiàn)這個接口，Counter和Gauage等不例外。它內(nèi)部提供了兩個函數(shù)，Collector用于收集用戶數(shù)據(jù)，將收集好的數(shù)據(jù)傳遞給傳入?yún)?shù)Channel就可;Descirbe函數(shù)用于描述這個Collector。

當(dāng)收集系統(tǒng)收集的數(shù)據(jù)太多時時，就可以自定義Collector收集的方式，優(yōu)化流程，并且在某些情況下如果已經(jīng)有了一個成熟的metrics，就不需要使用Counter,Gauage等這些數(shù)據(jù)結(jié)構(gòu)，直接在Collector內(nèi)部實(shí)現(xiàn)一個代理的功能即可。

基本上所有的export都是通過自定義Collector實(shí)現(xiàn)。一個簡單的Collector的實(shí)現(xiàn)export的代碼如下：

package main 
 
import ( 
 "github.com/prometheus/client_golang/prometheus" 
 "github.com/prometheus/client_golang/prometheus/promhttp" 
 "net/http" 
 "sync" 
) 
 
type ClusterManager struct { 
 sync.Mutex 
 Zone              string 
 metricMapCounters map[string]string 
 metricMapGauges   map[string]string 
} 
 
//Simulate prepare the data 
func (c *ClusterManager) ReallyExpensiveAssessmentOfTheSystemState() ( 
 metrics map[string]float64, 
) { 
 metrics = map[string]float64{ 
  "oom_crashes_total": 42.00, 
  "ram_usage":         6.023e23, 
 } 
 return 
} 
//通過NewClusterManager方法創(chuàng)建結(jié)構(gòu)體及對應(yīng)的指標(biāo)信息，代碼如下所示。 
// NewClusterManager creates the two Descs OOMCountDesc and RAMUsageDesc. Note 
// that the zone is set as a ConstLabel. (It's different in each instance of the 
// ClusterManager, but constant over the lifetime of an instance.) Then there is 
// a variable label "host", since we want to partition the collected metrics by 
// host. Since all Descs created in this way are consistent across instances, 
// with a guaranteed distinction by the "zone" label, we can register different 
// ClusterManager instances with the same registry. 
func NewClusterManager(zone string) *ClusterManager { 
 return &ClusterManager{ 
  Zone: zone, 
  metricMapGauges: map[string]string{ 
   "ram_usage": "ram_usage_bytes", 
  }, 
  metricMapCounters: map[string]string{ 
   "oom_crashes": "oom_crashes_total", 
  }, 
 } 
} 
//首先，采集器必須實(shí)現(xiàn)prometheus.Collector接口，也必須實(shí)現(xiàn)Describe和Collect方法。實(shí)現(xiàn)接口的代碼如下所示。 
// Describe simply sends the two Descs in the struct to the channel. 
// Prometheus的注冊器調(diào)用Collect來抓取參數(shù)  
// 將收集的數(shù)據(jù)傳遞到Channel中并返回  
// 收集的指標(biāo)信息來自Describe，可以并發(fā)地執(zhí)行抓取工作，但是必須要保證線程的安全  
 
func (c *ClusterManager) Describe(ch chan<- *prometheus.Desc) { 
 // prometheus.NewDesc(prometheus.BuildFQName(namespace, "", metricName), docString, labels, nil) 
 for _, v := range c.metricMapGauges { 
  ch <- prometheus.NewDesc(prometheus.BuildFQName(c.Zone, "", v), v, nil, nil) 
 } 
 
 for _, v := range c.metricMapCounters { 
  ch <- prometheus.NewDesc(prometheus.BuildFQName(c.Zone, "", v), v, nil, nil) 
 } 
} 
 
//Collect方法是核心，它會抓取你需要的所有數(shù)據(jù)，根據(jù)需求對其進(jìn)行分析，然后將指標(biāo)發(fā)送回客戶端庫。 
// 用于傳遞所有可能指標(biāo)的定義描述符  
// 可以在程序運(yùn)行期間添加新的描述，收集新的指標(biāo)信息  
// 重復(fù)的描述符將被忽略。兩個不同的Collector不要設(shè)置相同的描述符  
func (c *ClusterManager) Collect(ch chan<- prometheus.Metric) { 
 c.Lock() 
 defer c.Unlock() 
 m := c.ReallyExpensiveAssessmentOfTheSystemState() 
 for k, v := range m { 
  t := prometheus.GaugeValue 
  if c.metricMapCounters[k] != "" { 
   t = prometheus.CounterValue 
  } 
  c.registerConstMetric(ch, k, v, t) 
 } 
} 
// 用于傳遞所有可能指標(biāo)的定義描述符給指標(biāo) 
func (c *ClusterManager) registerConstMetric(ch chan<- prometheus.Metric, metric string, val float64, valType prometheus.ValueType, labelValues ...string) { 
 descr := prometheus.NewDesc(prometheus.BuildFQName(c.Zone, "", metric), metric, nil, nil) 
 if m, err := prometheus.NewConstMetric(descr, valType, val, labelValues...); err == nil { 
  ch <- m 
 } 
} 
 
func main() { 
 workerCA := NewClusterManager("xiaodian") 
 reg := prometheus.NewPedanticRegistry() 
 reg.MustRegister(workerCA) 
    //當(dāng)promhttp.Handler()被執(zhí)行時，所有metric被序列化輸出。題外話，其實(shí)輸出的格式既可以是plain text，也可以是protocol Buffers。 
 http.Handle("/metrics", promhttp.HandlerFor(reg, promhttp.HandlerOpts{})) 
 http.ListenAndServe(":8888", nil) 
}

此時就可以去http://localhost:8888/metrics 看到傳遞過去的數(shù)據(jù)了。

高質(zhì)量Exporter的編寫原則與方法

主要方法

參考鏈接：https://prometheus.io/docs/instrumenting/writing_exporters/。1.在訪問Exporter的主頁(即http://yourExporter/這樣的根路徑)時，它會返回一個簡單的頁面，這就是Exporter的落地頁(Landing Page)。落地頁中可以放文檔和幫助信息，包括監(jiān)控指標(biāo)項(xiàng)的說明。落地頁上還包括最近執(zhí)行的檢查列表、列表的狀態(tài)以及調(diào)試信息，這對故障排查非常有幫助。

2.一臺服務(wù)器或者容器上可能會有許多Exporter和Prometheus組件，它們都有自己的端口號。因此，在寫Exporter和發(fā)布Exporter之前，需要檢查新添加的端口是否已經(jīng)被使用[1]，建議使用默認(rèn)端口分配范圍之外的端口。

3.我們應(yīng)該根據(jù)業(yè)務(wù)類型設(shè)計好指標(biāo)的#HELP#TYPE的格式。這些指標(biāo)往往是可配置的，包括默認(rèn)開啟的指標(biāo)和默認(rèn)關(guān)閉的指標(biāo)。這是因?yàn)榇蟛糠种笜?biāo)并不會真正被用到，設(shè)計過多的指標(biāo)不僅會消耗不必要的資源，還會影響整體的性能。

其他方法

對于如何寫高質(zhì)量Exporter，除了合理分配端口號、設(shè)計落地頁、梳理指標(biāo)這3個方面外，還有一些其他的原則。

記錄Exporter本身的運(yùn)行狀態(tài)指標(biāo)。
可配置化進(jìn)行功能的啟用和關(guān)閉。
推薦使用YAML作為配置格式。
遵循度量標(biāo)準(zhǔn)命名的最佳實(shí)踐[2]，特別是_count、_sum、_total、_bucket和info等問題。
為度量提供正確的單位。
標(biāo)簽的唯一性、可讀性及必要的冗余信息設(shè)計。
通過Docker等方式一鍵配置Exporter。
盡量使用Collectors方式收集指標(biāo)，如Go語言中的MustNewConstMetric。
提供scrapes刮擦失敗的錯誤設(shè)計，這有助于性能調(diào)試。
盡量不要重復(fù)提供已有的指標(biāo)，如Node Exporter已經(jīng)提供的CPU、磁盤等信息。
向Prometheus公開原始的度量數(shù)據(jù)，不建議自行計算，Exporter的核心是采集原始指標(biāo)。

Redis Exporter源碼解析

在本章中，讀者可以發(fā)現(xiàn)開源領(lǐng)域有著不計其數(shù)的Exporter，阿里巴巴開源的Exporter就有RocketMQ Exporter、Sentinel Exporter、Sentry Exporter、Alibaba Cloud Exporter等多種。編寫Exporter和編寫Spring Boot Starter一樣，可以多參考其他優(yōu)秀的開源軟件的代碼。本節(jié)就來簡單分析一下運(yùn)維工作中用到的Redis Exporter源碼。在使用Redis Exporter時，可以通過redis_exporter--help命令查看完整的參數(shù)列表。默認(rèn)情況下，它在端口9192上運(yùn)行，并在路徑/metrics上暴露指標(biāo)?？梢酝ㄟ^--web.listen-addres和--web.telemetry-path命令來設(shè)置端口和路徑，代碼如下所示。

redis_exporter -web.listen-address=":8888" -web.telemetry-path="/node_metrics"

上述代碼將修改redis Exporter綁定到端口8888并在路徑/node_metrics上暴露指標(biāo)。這個邏輯是在源碼redis_exporter.go中實(shí)現(xiàn)的.Redis Exporter[3]主要通過Redis原生的命令獲取Redis所有的信息，它支持2.x、3.x、4.x、5.x和6.x版本。在源碼中，可以看到多處使用了doRedisCmd方法發(fā)送命令以獲取性能指標(biāo)，代碼如下所示。主要是通過原生的INFO命令獲取所有性能信息。該命令的返回結(jié)果詳情參考[4]。

infoAll, err := redis.String(doRedisCmd(c, "INFO", "ALL"))

生成的infoAll信息通過func (e *Exporter) extractInfoMetrics(ch chan<- prometheus.Metric, info string, dbCount int)繼續(xù)處理。它的主要目的是遍歷查詢到的結(jié)果，根據(jù)指標(biāo)生成一個hash值。源代碼如下所示：

func (e *Exporter) extractInfoMetrics(ch chan<- prometheus.Metric, info string, dbCount int) { 
 keyValues := map[string]string{} 
 handledDBs := map[string]bool{} 
 
 fieldClass := "" 
    //以換行符進(jìn)行分割 
 lines := strings.Split(info, "\n") 
 masterHost := "" 
 masterPort := "" 
    //遍歷查詢到的結(jié)果，根據(jù)指標(biāo)生成一個hash值 
 for _, line := range lines { 
  line = strings.TrimSpace(line) 
  log.Debugf("info: %s", line) 
        //去除帶#的注釋文件 
  if len(line) > 0 && strings.HasPrefix(line, "# ") { 
   fieldClass = line[2:] 
   log.Debugf("set fieldClass: %s", fieldClass) 
   continue 
  } 
        //去除不帶:的或者字符小于2的 
  if (len(line) < 2) || (!strings.Contains(line, ":")) { 
   continue 
  } 
        //以冒號進(jìn)行分割 
  split := strings.SplitN(line, ":", 2) 
  fieldKey := split[0] 
  fieldValue := split[1] 
        //將指標(biāo)名稱與值存到hash中 
  keyValues[fieldKey] = fieldValue 
 
  if fieldKey == "master_host" { 
   masterHost = fieldValue 
  } 
 
  if fieldKey == "master_port" { 
   masterPort = fieldValue 
  } 
        //按照集群和副本和哨兵模式進(jìn)行處理 
  switch fieldClass { 
 
  case "Replication": 
   if ok := e.handleMetricsReplication(ch, masterHost, masterPort, fieldKey, fieldValue); ok { 
    continue 
   } 
 
  case "Server": 
   e.handleMetricsServer(ch, fieldKey, fieldValue) 
 
  case "Commandstats": 
   e.handleMetricsCommandStats(ch, fieldKey, fieldValue) 
   continue 
 
  case "Keyspace": 
   if keysTotal, keysEx, avgTTL, ok := parseDBKeyspaceString(fieldKey, fieldValue); ok { 
    dbName := fieldKey 
 
    e.registerConstMetricGauge(ch, "db_keys", keysTotal, dbName) 
    e.registerConstMetricGauge(ch, "db_keys_expiring", keysEx, dbName) 
 
    if avgTTL > -1 { 
     e.registerConstMetricGauge(ch, "db_avg_ttl_seconds", avgTTL, dbName) 
    } 
    handledDBs[dbName] = true 
    continue 
   } 
 
  case "Sentinel": 
   e.handleMetricsSentinel(ch, fieldKey, fieldValue) 
  } 
 
  if !e.includeMetric(fieldKey) { 
   continue 
  } 
        //將收集到信息進(jìn)行按照一定規(guī)則進(jìn)行處理 
  e.parseAndRegisterConstMetric(ch, fieldKey, fieldValue) 
 } 
 
 for dbIndex := 0; dbIndex < dbCount; dbIndex++ { 
  dbName := "db" + strconv.Itoa(dbIndex) 
  if _, exists := handledDBs[dbName]; !exists { 
   e.registerConstMetricGauge(ch, "db_keys", 0, dbName) 
   e.registerConstMetricGauge(ch, "db_keys_expiring", 0, dbName) 
  } 
 } 
       
 e.registerConstMetricGauge(ch, "instance_info", 1, 
  keyValues["role"], 
  keyValues["redis_version"], 
  keyValues["redis_build_id"], 
  keyValues["redis_mode"], 
  keyValues["os"], 
  keyValues["maxmemory_policy"], 
  keyValues["tcp_port"], keyValues["run_id"], keyValues["process_id"], 
 ) 
 
 if keyValues["role"] == "slave" { 
  e.registerConstMetricGauge(ch, "slave_info", 1, 
   keyValues["master_host"], 
   keyValues["master_port"], 
   keyValues["slave_read_only"]) 
 } 
}

然后通過e.parseAndRegisterConstMetric(ch, fieldKey, fieldValue)方法，將收集到hash中的信息，按照一定的規(guī)則生成prometheus.Metric。核心代碼如下：

func (e *Exporter) registerConstMetric(ch chan<- prometheus.Metric, metric string, val float64, valType prometheus.ValueType, labelValues ...string) { 
 descr := e.metricDescriptions[metric] 
 if descr == nil { 
  descr = newMetricDescr(e.options.Namespace, metric, metric+" metric", labelValues) 
 } 
 
 if m, err := prometheus.NewConstMetric(descr, valType, val, labelValues...); err == nil { 
  ch <- m 
 } 
}

最后*Exporter.Collect的方法調(diào)用registerConstMetric方法，就完成了redis的info指標(biāo)的收集。其他指標(biāo)的收集原來也是相同的，有興趣的讀者可以自行閱讀。

總結(jié)

本文介紹了Exporter的概念。Exporter的來源主要有兩個：一個是社區(qū)提供的，一個是用戶自定義的。在實(shí)際生產(chǎn)中，官方提供的Exporter主要涵蓋數(shù)據(jù)庫、硬件、問題跟蹤及持續(xù)集成、消息系統(tǒng)、存儲、HTTP、API、日志、其他監(jiān)控系統(tǒng)等，這些已有的Exporter可以滿足絕大多數(shù)開發(fā)人員及運(yùn)維人員的需求。對于系統(tǒng)、軟件沒有Exporter的情況，本章也從數(shù)據(jù)規(guī)范、數(shù)據(jù)采集方式、代碼案例撰寫等方面帶領(lǐng)讀者體驗(yàn)了Exporter的設(shè)計與實(shí)踐，一步步指導(dǎo)讀者打造定制化Exporter。為了幫助讀者形成良好的代碼風(fēng)格并能夠真正編寫高質(zhì)量Exporter，本章還給出了編寫高質(zhì)量Exporter的建議，并結(jié)合 Redis Exporter的原理進(jìn)行了實(shí)戰(zhàn)解析。通過對本章的學(xué)習(xí)，讀者可以掌握使用和定制Exporter的能力。

[1] Exporter端口列表：https://github.com/prometheus/prometheus/wiki/Default-port-allocations。

[2] 標(biāo)準(zhǔn)命名最佳實(shí)踐：https://prometheus.io/docs/practices/naming。

[3] Redis Exporter地址：https://github.com/oliver006/redis_Exporter。

[4] Redis INFO命令地址：https://redis.io/commands/info。

責(zé)任編輯：武曉燕來源：運(yùn)維開發(fā)故事