2. 程式人生 > >Prometheus自定義指標

Prometheus自定義指標

阿新 • • 發佈：2021-03-10

1.  自定義指標

為了註冊自定義指標，請將MeterRegistry注入到元件中，例如：

public class Dictionary {

    private final List<String> words = new CopyOnWriteArrayList<>();

    Dictionary(MeterRegistry registry) {
        registry.gaugeCollectionSize("dictionary.size", Tags.empty(), this.words);
    }

    // ...

}

如果你的指標依賴於其它bean，那麼推薦使用MeterBinder註冊這些指標，例如：

@Bean
MeterBinder queueSize(Queue queue) {
    return (registry) -> Gauge.builder("queueSize", queue::size).register(registry);
}

使用MeterBinder可以確保設定正確的依賴關係，並且在檢索指標的值時bean是可用的。預設情況下，來自所有MeterBinder bean的指標將自動繫結到Spring管理的MeterRegistry。如果您發現在元件或應用程式之間重複檢測一個指標，那麼MeterBinder實現也會很有用。 

文件參見

https://docs.spring.io/spring-boot/docs/current/reference/html/production-ready-features.html#production-ready-metrics-export-prometheus

https://docs.spring.io/spring-boot/docs/current/reference/html/production-ready-features.html#production-ready-metrics-custom

 

接下來，還是用之前的prometheus-example那個例子，我們來自定義業務指標

重新回顧一下

依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-registry-prometheus</artifactId>
    <scope>runtime</scope>
</dependency>

application.yml

spring:
  application:
    name: prometheus-example
management:
  endpoints:
    web:
      exposure:
        include: "*"
  metrics:
    tags:
      application: ${spring.application.name}

prometheus.yml

scrape_configs:
  - job_name: 'springboot-prometheus'
    metrics_path: '/actuator/prometheus'
    static_configs:
      - targets: ['192.168.100.93:8080','192.168.100.16:8080']

啟動專案

# 啟動Prometheus
./prometheus --config.file=prometheus.yml

# 啟動Grafana
bin/grafana-server web

下面改造一下，新增一個AOP來模擬記錄訂單相關指標

package com.cjs.example.aop;

import com.cjs.example.domain.OrderVO;
import io.micrometer.core.instrument.Counter;
import io.micrometer.core.instrument.DistributionSummary;
import io.micrometer.core.instrument.MeterRegistry;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * @author ChengJianSheng
 * @since 2021/3/8
 */
@Aspect
@Component
public class OrderAspect {

    private Counter orderCounter;

    private DistributionSummary orderSummary;

    public OrderAspect(MeterRegistry registry) {
        orderCounter = registry.counter("order_quantity_total", "status", "success");
        orderSummary = registry.summary("order_amount_total", "status", "success");
    }

//    @PostConstruct
//    public void init() {
//
//    }


    @Pointcut("execution(public * com.cjs.example.controller.OrderController.createOrder(..))")
    public void pointcut() {

    }

    @Around("pointcut()")
    public Object doAround(ProceedingJoinPoint pjp) throws Throwable {
        Object result = pjp.proceed();
        OrderVO orderVO = (OrderVO) result;

        orderCounter.increment();
        orderSummary.record(orderVO.getAmount().doubleValue());

        return result;
    }

} 

專案結構如圖

用postman造幾條資料

為了好看，我們在Grafana上建立一個dashboard，其中包含4個面板，對應四個指標

輸入指標、設定名稱、選擇檢視、設定屬性

最後，記得儲存。現在，我們有三個儀表盤了

2.  自動發現抓取目標

在實際專案中，我們不可能一個一個手動的配置要抓取的目標，每次都去修改prometheus.yml檔案，然後再重啟服務，想都不要想，不可能這麼做。

為此，我們需要動態發現目標。Prometheus支援很多的服務發現配置，比如：zookeeper、eureka、kubernetes等等

詳見 https://prometheus.io/docs/prometheus/latest/configuration/configuration/#scrape_config

這裡以Eureka為例，看看Prometheus如何從eureka中動態發現服務

https://prometheus.io/docs/prometheus/latest/configuration/configuration/#eureka_sd_config

https://prometheus.io/docs/prometheus/latest/configuration/configuration/#relabel_config

首先，我們建立一個專案當Eureka Server，並啟動它

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>eureka-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka-server</name>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2020.0.1</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.yml

server:
  port: 8761

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false
fetchRegistry: false
serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 

啟動類上加@EnableEurekaServer 

eureka server 啟動以後，接下來，我們改造一下剛才的專案prometheus-example

首先引入eureka client，這樣的話完成的pom.xml就變成這樣了

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.cjs.example</groupId>
    <artifactId>prometheus-example</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>prometheus-example</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2020.0.1</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>io.micrometer</groupId>
            <artifactId>micrometer-registry-prometheus</artifactId>
            <scope>runtime</scope>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.6</version>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

修改application.yml

這裡有個地方要注意，原來我們沒有加上下文路徑（server.servlet.context-path）,但是一般專案是會設定的，所以這次我們也加上。

（PS：專案GitHub地址  https://github.com/chengjiansheng/prometheus-example）

完整的配置如下：

server:
  port: 8080
  servlet:
    context-path: /hello

spring:
  application:
    name: prometheus-example

management:
  endpoints:
    web:
      exposure:
        include: "*"
  metrics:
    tags:
      application: ${spring.application.name}

eureka:
  client:
    serviceUrl:
      defaultZone: http://192.168.100.93:8761/eureka/
  instance:
    metadata-map:
      "prometheus.scrape": "true"
      "prometheus.path": "${server.servlet.context-path}/actuator/prometheus"
      "prometheus.port": "${server.port}" 

注意：

1、加了server.servlet.context-path以後，抓取的路徑就不再是 http://192.168.100.93:8080/actuator/prometheus了，而是變成了 http://192.168.100.93:8080/hello/actuator/prometheus了。之前我們prometheus.yml檔案裡靜態配置抓取目標的metrics_path是/actuator/prometheus，但是現在不能這樣寫了，因為加了應用上下文路徑，而且每個服務都不一樣。

2、為了能夠根據各服務動態自定義指標路徑（metrics_path）,最最重要的是下面這三行

eureka:
  instance:
    metadata-map:
      "prometheus.scrape": "true"
      "prometheus.path": "${server.servlet.context-path}/actuator/prometheus"
      "prometheus.port": "${server.port}" 

prometheus是通過eureka發現服務的，因此只有將服務的指標路徑（抓取地址）寫到eureka裡，prometheus才能拿到

換言之，只有服務在註冊的時候，將自己暴露的端點（endpoint）以元資料的方式寫到eureka中prometheus才能正確的從目標抓取資料

修改prometheus.yml，改為通過eureka獲取抓取目標

scrape_configs:
  - job_name: 'eureka-prometheus'
    eureka_sd_configs:
      - server: http://192.168.100.93:8761/eureka
    relabel_configs:
      - source_labels: [__meta_eureka_app_instance_metadata_prometheus_path]
        action: replace
        target_label: __metrics_path__
        regex: (.+)

 

https://github.com/prometheus/prometheus/blob/release-2.25/documentation/examples/prometheus-eureka.yml

https://github.com/prometheus/prometheus/blob/main/documentation/examples/prometheus-eureka.yml

https://github.com/prometheus/prometheus/tree/main/documentation/examples

這裡不得不提的是relabel_configs

Relabeling（重新標記）是一種強大的工具，可以在抓取目標之前動態重寫目標的標籤集。每個抓取配置可以配置多個重新標記步驟。 它們按照在配置檔案中出現的順序應用於每個目標的標籤集。

Relabeling是在抓取(scraping)前修改target和它的labels

3.  補充：Prometheus儲存

Prometheus自帶一個本地磁碟時間序列資料庫，但也可以選擇與遠端儲存系統整合。

本地儲存

Prometheus的本地時間序列資料庫在本地儲存上以定製的、高效的格式儲存資料。

注意，本地儲存的一個限制是它沒有叢集或副本。因此，在驅動器或節點中斷時，它不是任意可伸縮或持久的，應該像任何其他單節點資料庫一樣進行管理。建議使用RAID來提高儲存可用性，建議使用快照作為備份。使用適當的架構，可以在本地儲存中保留多年的資料。也可以採用外部儲存。 

TSDB （時間序列資料庫，簡稱時序資料庫）

Prometheus具有幾個用於配置本地儲存的引數。 最重要的是：

  • --storage.tsdb.path: Prometheus寫入資料庫的位置，預設是data/
  • --storage.tsdb.retention.time: 什麼時候刪除舊資料，預設是15天
  • --storage.tsdb.retention.size: 要保留的最大儲存塊位元組數。最舊的資料將首先被刪除。預設為0或禁用。這個標誌是實驗性的，在未來的版本中可能會改變。支援的單位:B、KB、MB、GB、TB、PB、EB。例如:“512 mb” 

Prometheus平均每個樣本僅儲存1~2個位元組.因此，要規劃Prometheus伺服器的容量，可以使用以下公式粗略計算：

 needed_disk_space = retention_time_seconds * ingested_samples_per_second * bytes_per_sample

Prometheus通過以下三種方式與遠端儲存系統整合：

  • Prometheus可以將其提取的樣本以標準格式寫入遠端URL
  • Prometheus可以以標準格式從其他Prometheus伺服器接收樣本
  • Prometheus可以以標準格式從遠端URL讀取樣本資料 

 

&n

相關推薦

Prometheus自定義指標

1.  自定義指標 為了註冊自定義指標，請將MeterRegistry注入到元件中，例如： public class Dictionary { private final List<String> words = new CopyOnWriteArrayList<>

通過prometheus實現k8s hpa自定義指標 (三)

在本系列文章的上一節通過prometheus實現k8s hpa自定義指標 (二)，我們從開發者角度理解k8s hpa工作的流程。這節我們將通過一個最基礎的custom metrics API server介紹開發一個自定義metrics-apiserver需要完

簡單4步，利用Prometheus Operator實現自定義指標監控

> 本文來自[Rancher Labs](https://mp.weixin.qq.com/s/ZZPMHI73GuYaT2MyqHfpxg "Rancher Labs") 在過去的文章中，我們花了相當大的篇幅來聊關於監控的話題。這是因為當你正在管理Kubernetes叢集時，一切都會以極快的速度發生

K8S 資源指標API及自定義指標API

資源指標API及自定義指標API 資源指標：metrics-server 自定義指標 1.8以後引入了資源api指標監視 資源指標：metrics-server 自定義指標：prometheus，k8s-prometheus-adapter     k8s的中的prome

kubernetes學習筆記之十二：資源指標API及自定義指標API

第一章、前言 以前是用heapster來收集資源指標才能看，現在heapster要廢棄了從1.8以後引入了資源api指標監視 資源指標：metrics-server(核心指標) 自定義指標：prometheus，k8s-prometheus-adapter(將Prometheus採集的資料轉換為指

AMap高德地圖自定義指標，定位mapview新方法!

最近公司需要做範圍內打卡的功能，所以研究了下高德地圖的SDK，首先註冊申請key就不多講了，百度有很詳細的資料，下面主要記錄下實現方法。demo地址在最下方：下載後自行更新cocoapod檔案下載依

.NetCore下使用Prometheus實現系統監控和警報 （六）進階Grafana集成自定義收集指標

之前 技術 bsp （六） com ota 選擇 netcore 面板 Prometheus中包含了很多收集指標，那麽我們怎來在Grafana中來使用呢？ 接下來我們還是以之前自定義的來演示如圖：我們在Prometheus中已經可以看到這個之前我們自定義的類型了 關

自定義Metrics：讓Prometheus監控你的應用程式

前言 Prometheus社群提供了大量的官方以及第三方Exporters，可以滿足Prometheus的採納者快速實現對關鍵業務，以及基礎設施的監控需求。如上所示，一個簡單的應用以及環境架構。一般而言，我們通常會從幾個層面進行監控指標的採集： 入口閘道器：這裡可以是Nginx/HaProxy這一類

Android學習筆記之為Dialog自定義佈局，並說明空指標問題

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

Problem B: 指標：呼叫自定義交換函式，完成5個浮點數從小到大排列

#include<stdio.h> int swap(float *p1,float *p2) { float flag; if(*p1>*p2) { flag=*p1; *p1=*p2; *p2=flag;

Problem D: 指標：呼叫自定義排序函式sort，對輸入的n個數進行從小到大輸出。

#include<stdio.h> int sort(int *p,int n) { int i,j,temp; for(i=0;i<n-1;i++) for(j=i;j<n;j++) if(p[i]>p[j]) {

CSS自定義滑鼠指標樣式

原文連結: http://davidwalsh.name/css-custom-cursorDemo地址: http://davidwalsh.name/demo/css-custom-cursor.php原文日期: 2014-09-16翻譯日期: 2014-09-17翻譯人

通過自定義prometheus資料實現k8s hpa

核心指標管道 從 Kubernetes 1.8 開始，資源使用指標（如容器 CPU 和記憶體使用率）通過 Metrics API 在 Kubernetes 中獲取。 這些指標可以直接被使用者訪問(例如通過使用 kubectl top 命令)，或由叢集中的控制

map中使用自定義類指標作為key

//先上程式碼 #pragma once //想用類作為key，必須過載<運算子 或者提供 //想用指標作為key，也是可以的，不過要自己提供仿函式 class CBase { public:     explicit CBase(int a);     ~CBase(void); private:

css Cursor:url()自定義滑鼠指標樣式為圖片

css自定義滑鼠指標樣式為圖片Cursor:url()的使用，今天在專案中，要用到自定義滑鼠樣式，格式： css:{cursor:url('絕對路徑的圖片(格式：cur,ico)'),-moz-zoom-out;}//FF下面 css:{cursor:url('絕對路徑')

解決自定義securityMetadataSource不能使用依賴注入的問題，nullpointer問題，空指標問題

spring3,spring security,MySecurityMetadataSource,自定義securityMetadataSource,依賴注入,註解,注入,空指標異常,nullpointer,service 解決的問題，nullpointer問題，空指標問題我在配置spring3和S

自定義函式 返回多個值（指標）

#include "iostream.h"void calcu(int *a,int *b,int *l,int *angle){//進行相應的操作//比如...*l += *a;*angle += *

Android實現HID滑鼠的指標自定義

寫在前面:本文所提供方法僅供研究學習，不可用於商業用途，轉載請註明出處。 好，正文開始... 首先介紹下藍芽HID裝置，指市面上出售的可用於連線PC、Android的可輸入裝置，這類裝置遵循了hid通訊協議，可以用於輸入操作（如按鍵、滑鼠移動等），作為一個互動裝置存在。

findViewById自定義控制時出現空指標異常

開發平臺  ADT 22 我在使用百度地圖介面的時候，用到MapView控制元件，然後在Activity中使用mMapView = (MapView)findViewById(R.id.bmapView)，似乎沒什麼問題， 然後在這裡丟擲空指標異常，我首先想的就是難道這個

自定義view中bitmap.getwidth()方法報空指標

自定義view 的時候，在構造方法中初始化bitmap，一直報null。經過修改圖片獲取放在onDraw中，正常，原因未知。程式碼如下：@Override protected void onDraw(Canvas canvas) { super.onDraw(canv