Managed Service for Prometheus:Push data using Pushgateway

Add data protection configuration (optional)

1. Get a token: In the navigation pane on the left, choose Settings. On the Settings tab, in the Token section, click Generate Token.

2. Pass the token: After generating the token, use one of the following methods to pass it.

   • Method 1: Set the token in the client request header to push data normally. Otherwise, the system rejects the write request. Use the following header format:

     Authorization: Bearer <token>

   • Method 2: The Pushgateway SDK supports only basic Auth and does not support JWT. To use the SDK with authentication, use the BasicAuth interface and set the password to the token. The server side supports this authentication method. Method 1 requires additional development effort. The following example uses the Go SDK.

     pusher := push.New(url, "test").
             Collector(completionTime).Client(http.DefaultClient).
             Grouping("key1", "test1").Grouping("key2", "dfdf/sdsd/").
             .BasicAuth("admin", "actual token value").
             Format(expfmt.FmtProtoDelim)

1. Grant CMS read and write permission to a RAM user

If your Alibaba Cloud Prometheus instance was created by an Alibaba Cloud account and you need to use a RAM user’s AccessKey ID and AccessKey secret for remote read and write operations, first grant the RAM user CMS read and write permission.

1. Log on to the Resource Access Management (RAM) console using an Alibaba Cloud account or a RAM administrator. In the navigation pane on the left, choose Permission Management > Authorization.

2. On the Authorization page, click Create Authorization. On the Create Authorization page, configure the following parameters.

   Parameter	Description
   Resource Scope	Select a resource scope as needed.
   Principal	Select the RAM user that you want to authorize.
   Policy	Select AliyunPrometheusMetricWriteAccess or AliyunCloudMonitorFullAccess.

3. Click OK, and then click Close.

2. Push data

completionTime := prometheus.NewGauge(prometheus.GaugeOpts{
    Name: "db_backup_last_completion_timestamp_seconds",
    Help: "The timestamp of the last successful completion of a DB backup.",
})
completionTime.SetToCurrentTime()
url :   = "https://k8s-log-c8b5d0a212ffa41cxxxx.cn-hangzhou.log.aliyuncs.com/prometheus/k8s-log-c8b5d0a212ffa41c0a5xxxx/aliyun-prom-c8b5d0a212ffa41c0xxxx/api/v1/pushgateway"
pusher := push.New(url, "test").
    Collector(completionTime).Client(http.DefaultClient).
    Grouping("key1", "test1").Grouping("key2", "dfdf/sdsd/").
    BasicAuth("ak", "sk").  
    Format(expfmt.FmtProtoDelim)
if err := pusher.Push(); err != nil {
    fmt.Println("Could not push completion time to PushGateway: ", err)
}

CollectorRegistry registry = new CollectorRegistry();
Gauge duration = Gauge.build()
        .name("my_batch_job_duration_seconds").help("Duration of my batch job in seconds.").register(registry);
Gauge.Timer durationTimer = duration.startTimer();
try {
    // Your code here.
    // This is only added to the registry after success,
    // so that a previous success in the Pushgateway isn't overwritten on failure.
    Gauge lastSuccess = Gauge.build()
            .name("my_batch_job_last_success").help("Last time my batch job succeeded, in unixtime.").register(registry);
    lastSuccess.setToCurrentTime();
} finally {
    durationTimer.setDuration();
    PushGateway pg = new PushGateway(new URL("https://k8s-log-c8b5d0a212ffa41cxxxx.cn-hangzhou.log.aliyuncs.com/prometheus/k8s-log-c8b5d0a212ffa41c0a5xxxx/aliyun-prom-c8b5d0a212ffa41c0xxxx/api/v1/pushgateway"));       
    pg.setConnectionFactory(new BasicAuthHttpConnectionFactory("ak", "sk"));  
    pg.pushAdd(registry, "my_batch_job");
}

echo "some_metric 3.14" | curl -u 'ak:sk' -H "Content-Type: text/plain; version=0.0.4; charset=utf-8" --data-binary @- https://k8s-log-c8b5d0a212ffa41cxxxx.cn-hangzhou.log.aliyuncs.com/prometheus/k8s-log-c8b5d0a212ffa41c0a5xxxx/aliyun-prom-c8b5d0a212ffa41c0xxxx/api/v1/pushgateway/metrics/job/job_name/label_key_1/label_value_1/label_key_2/label_value_2