prometheus拉取target的metrics时,都是错开工夫别离拉取的,这样有以下益处:

  • 防止prometheus实例启动太多的goroutine同时拉取;
  • 多prometheus实例拉取同一个target时,防止同时拉取对target造成流量压力;

单prometheus实例内的不同target

单实例内的不同target,不是在某个时刻一起拉取,而是错开工夫别离拉取。比方scrape_interval=30s,不同target的拉取工夫如下:

  • job=prometheus:20秒、50秒拉取;
  • job=node-exporter:04秒、34秒拉取;
  • job=pvc-test:07秒、37秒拉取;
> select * from up where job='prometheus' order by time desc limit 5;name: uptime                     __name__ __type__ instance       job        value----                     -------- -------- --------       ---        -----2021-09-24T05:52:20.665Z up       gauge    localhost:9090 prometheus 12021-09-24T05:51:50.665Z up       gauge    localhost:9090 prometheus 12021-09-24T05:51:20.665Z up       gauge    localhost:9090 prometheus 12021-09-24T05:50:50.665Z up       gauge    localhost:9090 prometheus 12021-09-24T05:50:20.665Z up       gauge    localhost:9090 prometheus 1>> select * from up where job='node-exporter' order by time desc limit 5;name: uptime                     __name__ __type__ instance        job           value----                     -------- -------- --------        ---           -----2021-09-24T05:52:34.184Z up       gauge    10.21.1.74:9100 node-exporter 02021-09-24T05:52:04.183Z up       gauge    10.21.1.74:9100 node-exporter 02021-09-24T05:51:34.183Z up       gauge    10.21.1.74:9100 node-exporter 02021-09-24T05:51:04.183Z up       gauge    10.21.1.74:9100 node-exporter 02021-09-24T05:50:34.183Z up       gauge    10.21.1.74:9100 node-exporter 0>> select * from up where job='pvc-test' order by time desc limit 5;name: uptime                     __name__ __type__ instance       job      value----                     -------- -------- --------       ---      -----2021-09-24T05:53:07.315Z up       gauge    127.0.0.1:9999 pvc-test 02021-09-24T05:52:37.315Z up       gauge    127.0.0.1:9999 pvc-test 02021-09-24T05:52:07.315Z up       gauge    127.0.0.1:9999 pvc-test 02021-09-24T05:51:37.315Z up       gauge    127.0.0.1:9999 pvc-test 02021-09-24T05:51:07.315Z up       gauge    127.0.0.1:9999 pvc-test 0

多prometheus实例

在HA场景下,不同的prometheus实例可能拉取雷同的target。
多个prometheus实例同时启动时,开始拉取的工夫也要随机错开,否则会呈现多个实例同时拉取同一个target的景象。

实现机制

通过全局的scrape jitterSeed实现:

  • 不同实例:jitterSeed是跟特定prometheus实例相干的uint64哈希值,不同实例的jitterSeed不同;
  • 单实例不同target: 应用target哈希值与jitterSeed做异或操作,失去target拉取的启动工夫,不同的target启动工夫不同;

prometheus实例的scrape jitterSeed的计算

// unit64jitterSeed=hash({hostname}+{extertalLabels})

不同实例的hostname/externalLabels个别不同,故计算出来的jitterSeed值也不同。

// scrape/manager.go// setJitterSeed calculates a global jitterSeed per server relying on extra label set.func (m *Manager) setJitterSeed(labels labels.Labels) error {    h := fnv.New64a()    hostname, err := getFqdn()    if err != nil {        return err    }    if _, err := fmt.Fprintf(h, "%s%s", hostname, labels.String()); err != nil {        return err    }    m.jitterSeed = h.Sum64()    return nil}

prometheus实例内target拉取启动工夫的计算
target被拉取前,先随机期待一个工夫,而后再用interval固定距离循环拉取:

// scrape/scrape.gofunc (sl *scrapeLoop) run(interval, timeout time.Duration, errc chan<- error) {    //期待一段时间再开始    select {    case <-time.After(sl.scraper.offset(interval, sl.jitterSeed)):        // Continue after a scraping offset.    case <-sl.ctx.Done():        close(sl.stopped)        return    }    // interval固定距离拉取    ticker := time.NewTicker(interval)    defer ticker.Stop()        for {        // HTTP拉取        last = sl.scrapeAndReport(interval, timeout, last, errc)        select {        ......        case <-ticker.C:        }    }}   

不同target有不同的等待时间,这样就能够将不同target的开始工夫错开。

//target等待时间的计算方法offset=((hash(target) ^ jitterSeed) % interval)

代码实现:

// scrape/target.go// offset returns the time until the next scrape cycle for the target.// It includes the global server jitterSeed for scrapes from multiple Prometheus to try to be at different times.func (t *Target) offset(interval time.Duration, jitterSeed uint64) time.Duration {    now := time.Now().UnixNano()    // Base is a pinned to absolute time, no matter how often offset is called.    var (        base   = int64(interval) - now%int64(interval)        offset = (t.hash() ^ jitterSeed) % uint64(interval)        next   = base + int64(offset)    )    if next > int64(interval) {        next -= int64(interval)    }    return time.Duration(next)}