Início / coding / Perguntas / 79349586
Accepted
27P
Asked: 2025-01-12 16:30:30 +0800 CST

VictoriaMetrics: objeto 'metric' ausente

  • 772

Você poderia me dizer qual é o payload json correto para enviar para VictoriaMetrics?

Carga JSON que estou enviando e recebendo erro:

[{"metric":{"__name__":"cpu_usage_percent","instance":"localhost:9100","job":"Alexs-MBP.Home"},"timestamps":[1736670067000],"values":[7.737105]}]

Erro:

2025-01-12T08:21:09.324Z    error   VictoriaMetrics/lib/protoparser/vmimport/parser.go:239  skipping json line "[{\"metric\":{\"__name__\":\"cpu_usage_percent\",\"instance\":\"localhost:9100\",\"job\":\"Alexs-MBP.Home\"},\"timestamps\":[1736670067000],\"values\":[7.737105]}]" because of error: missing `metric` object

Função:

func sendMetricToVictoria(metricName string, value float32, timestampStr string) error {
    timestamp, err := strconv.ParseInt(timestampStr, 10, 64)
    if err != nil {
        return fmt.Errorf("invalid timestamp format: %v", err)
    }

    // Get Hostname
    hostname, err := os.Hostname()
    if err != nil {
        return fmt.Errorf("error getting hostname: %v", err)
    }

    // Prepare the payload for VictoriaMetrics
    data := []map[string]interface{}{
        {
            "metric": map[string]interface{}{
                "__name__": metricName,       // Name of the metric
                "job":      hostname,         // Add the job label
                "instance": "localhost:9100", // Add the instance label
            },
            "values":     []float32{value},
            "timestamps": []int64{timestamp * 1000}, // Convert seconds to milliseconds
        },
    }

    log.Printf("JSON being sent: %v\n", data)

    // Send data to VictoriaMetrics
    return sendToVictoriaMetrics(data)
}

API:

http://127.0.0.1:8428/api/v1/import

***************** ATUALIZAÇÃO - CORRIGIDO **********************

json incorreto

[{"metric":{"__name__":"cpu_usage_percent","instance":"localhost:9100","job":"Alexs-MBP.Home"},"timestamps":[1736799662748],"values":[4.090150356292725]}]

JSON correto (erro bobo - usei array [])

{"metric":{"__name__":"cpu_usage_percent","instance":"localhost:9100","job":"Alexs-MBP.Home"},"timestamps":[1736800254000],"values":[5.096073627471924]}


func sendMetricToVictoria(metricName string, value float32, timestampStr string) error {
    timestamp, err := strconv.ParseInt(timestampStr, 10, 64)
    if err != nil {
        return fmt.Errorf("invalid timestamp format: %v", err)
    }

    // Get Hostname
    hostname, err := os.Hostname()
    if err != nil {
        return fmt.Errorf("error getting hostname: %v", err)
    }

    // Prepare the payload for VictoriaMetrics
    data := map[string]interface{}{
        "metric": map[string]string{
            "__name__": metricName,       // Metric name
            "job":      hostname,         // Job label
            "instance": "localhost:9100", // Instance label
        },
        "values":     []float64{float64(value)}, // Convert to float64 as required by VictoriaMetrics
        "timestamps": []int64{timestamp * 1000}, // Convert to milliseconds
    }

    // Log the JSON for debugging
    jsonData, _ := json.MarshalIndent(data, "", "  ")
    log.Printf("Sending JSON to VictoriaMetrics: %s\n", string(jsonData))

    // Send data to VictoriaMetrics
    return sendToVictoriaMetrics(data)
}
json

2 respostas

  1. Best Answer

    De https://docs.victoriametrics.com/#how-to-import-time-series-data e https://docs.victoriametrics.com/#json-line-format , esse endpoint deseja uma carga útil de linha JSON , ou seja, algo como

    {"foo": "bar 1"}
{"foo": "bar 2"}

    enquanto se eu olhar para sua carga útil, ela é JSON simples , ou seja, a estrutura de dados externa é uma matriz JSON:

    [
  {"foo": "bar 1"},
  {"foo": "bar 2"},
  ...
]

    Para mais informações sobre JSON-line, veja por exemplo https://jsonlines.org/ .

    Criar linhas JSON com Go é simples e pode ser feito com o pacote stdlib json: em vez de marshaling a fatia inteira, itere sobre a fatia e marshaling os elementos individuais.

    • 2

  2. Veja este exemplo de código go https://go.dev/play/p/LqLMWdNOBD9

    func importSeries(metric string, value float64, timestamp int64) {
  b := strings.Builder{}
  job, instance := "myjob", "myinstance"
  b.WriteString(fmt.Sprintf("{\"metric\":{\"__name__\":%q, \"instance\":%q, \"job\":%q}", metric, instance, job))
  b.WriteString(fmt.Sprintf(",\"timestamps\":[%d]", timestamp))
  b.WriteString(fmt.Sprintf(",\"values\":[%v]}", value))
  fmt.Println(b.String())
}

    Claro, essa é uma implementação muito ingênua sem batching ou envio de multilinhas. Você pode encontrar mais configurações de produção para envio de dados aqui e aqui .

    • 0

relate perguntas