mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2026-05-17 00:26:36 +03:00
relabel debug: support multiple lines metrics input
This commit is contained in:
@@ -35,12 +35,6 @@ func writeRelabelDebug(w io.Writer, isTargetRelabel bool, targetID, metric, rela
|
||||
return
|
||||
}
|
||||
|
||||
labels, err := promutil.NewLabelsFromString(metric)
|
||||
if err != nil {
|
||||
err = fmt.Errorf("cannot parse metric: %w", err)
|
||||
WriteRelabelDebugSteps(w, targetURL, targetID, format, nil, metric, relabelConfigs, err)
|
||||
return
|
||||
}
|
||||
pcs, err := ParseRelabelConfigsData([]byte(relabelConfigs))
|
||||
if err != nil {
|
||||
err = fmt.Errorf("cannot parse relabel configs: %w", err)
|
||||
@@ -48,8 +42,33 @@ func writeRelabelDebug(w io.Writer, isTargetRelabel bool, targetID, metric, rela
|
||||
return
|
||||
}
|
||||
|
||||
dss, targetURL := newDebugRelabelSteps(pcs, labels, isTargetRelabel)
|
||||
WriteRelabelDebugSteps(w, targetURL, targetID, format, dss, metric, relabelConfigs, nil)
|
||||
// metric input may contain multiple lines, and it's good to add support and print the debug steps for each of them.
|
||||
// however, the target URL won't change
|
||||
metrics := strings.Split(metric, "\n")
|
||||
dsss := make([][]DebugStep, 0, len(metrics))
|
||||
var lastErr error
|
||||
|
||||
for _, m := range metrics {
|
||||
// try to trim all the special characters and space first
|
||||
m = strings.TrimSpace(m)
|
||||
labels, err := promutil.NewLabelsFromString(m)
|
||||
if err != nil {
|
||||
lastErr = err
|
||||
continue
|
||||
}
|
||||
dss, tURL := newDebugRelabelSteps(pcs, labels, isTargetRelabel)
|
||||
targetURL = tURL
|
||||
dsss = append(dsss, dss)
|
||||
}
|
||||
|
||||
// break here if all failed
|
||||
if len(dsss) == 0 && lastErr != nil {
|
||||
err = fmt.Errorf("cannot parse metric: %w", err)
|
||||
WriteRelabelDebugSteps(w, targetURL, targetID, format, nil, metric, relabelConfigs, lastErr)
|
||||
return
|
||||
}
|
||||
|
||||
WriteRelabelDebugSteps(w, targetURL, targetID, format, dsss, metric, relabelConfigs, nil)
|
||||
}
|
||||
|
||||
func newDebugRelabelSteps(pcs *ParsedConfigs, labels *promutil.Labels, isTargetRelabel bool) ([]DebugStep, string) {
|
||||
|
||||
@@ -6,15 +6,15 @@
|
||||
|
||||
{% stripspace %}
|
||||
|
||||
{% func RelabelDebugSteps(targetURL, targetID, format string, dss []DebugStep, metric, relabelConfigs string, err error) %}
|
||||
{% func RelabelDebugSteps(targetURL, targetID, format string, dsss [][]DebugStep, metric string, relabelConfigs string, err error) %}
|
||||
{% if format == "json" %}
|
||||
{%= RelabelDebugStepsJSON(targetURL, targetID, dss, metric, relabelConfigs, err) %}
|
||||
{%= RelabelDebugStepsJSON(targetURL, targetID, dsss, metric, relabelConfigs, err) %}
|
||||
{% else %}
|
||||
{%= RelabelDebugStepsHTML(targetURL, targetID, dss, metric, relabelConfigs, err) %}
|
||||
{%= RelabelDebugStepsHTML(targetURL, targetID, dsss, metric, relabelConfigs, err) %}
|
||||
{% endif %}
|
||||
{% endfunc %}
|
||||
|
||||
{% func RelabelDebugStepsHTML(targetURL, targetID string, dss []DebugStep, metric, relabelConfigs string, err error) %}
|
||||
{% func RelabelDebugStepsHTML(targetURL, targetID string, dsss [][]DebugStep, metric string, relabelConfigs string, err error) %}
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
@@ -60,11 +60,13 @@ function submitRelabelDebugForm(e) {
|
||||
</form>
|
||||
</div>
|
||||
|
||||
{% for _, dss := range dsss %}
|
||||
<div class="row">
|
||||
<main class="col-12">
|
||||
{%= relabelDebugSteps(dss, targetURL, targetID) %}
|
||||
</main>
|
||||
</div>
|
||||
{% endfor %}
|
||||
</div>
|
||||
</body>
|
||||
</html>
|
||||
@@ -77,7 +79,7 @@ function submitRelabelDebugForm(e) {
|
||||
</div>
|
||||
|
||||
<div>
|
||||
Labels:<br/>
|
||||
Labels (One label set per line. Multiple lines will be treated as multiple label sets):<br/>
|
||||
<textarea name="metric" style="width: 100%; height: 5em; font-family: monospace" class="m-1">{%s metric %}</textarea>
|
||||
</div>
|
||||
{% endfunc %}
|
||||
@@ -151,45 +153,52 @@ function submitRelabelDebugForm(e) {
|
||||
{% endif %}
|
||||
{% endfunc %}
|
||||
|
||||
{% func RelabelDebugStepsJSON(targetURL, targetID string, dss []DebugStep, metric, relabelConfigs string, err error) %}
|
||||
{% func RelabelDebugStepsJSON(targetURL, targetID string, dsss [][]DebugStep, metric string, relabelConfigs string, err error) %}
|
||||
{
|
||||
{% if err != nil %}
|
||||
"status": "error",
|
||||
"error": {%q= fmt.Sprintf("Error: %s", err) %}
|
||||
{% else %}
|
||||
{% code var hasError bool %}
|
||||
"status": "success",
|
||||
"steps": [
|
||||
{% for i, ds := range dss %}
|
||||
{% code
|
||||
inLabels, inErr := promutil.NewLabelsFromString(ds.In)
|
||||
outLabels, outErr := promutil.NewLabelsFromString(ds.Out)
|
||||
changedLabels := getChangedLabelNames(inLabels, outLabels)
|
||||
%}
|
||||
"metrics": [
|
||||
{% for idx, dss := range dsss %}
|
||||
{% code var hasError bool %}
|
||||
{
|
||||
"inLabels": {%q= labelsWithHighlight(inLabels, changedLabels, "#D15757") %},
|
||||
"outLabels": {%q= labelsWithHighlight(outLabels, changedLabels, "#4495e0") %},
|
||||
"rule": {%q= ds.Rule %},
|
||||
"errors": {
|
||||
{% if inErr != nil %}
|
||||
"inLabels": {%q= `<span style="color: #D15757">`+inErr.Error()+`</span>` %}{% if outErr != nil %},{% endif %}
|
||||
{%code hasError = true %}
|
||||
{% else %}
|
||||
{% endif %}
|
||||
{% if outErr != nil %}
|
||||
"outLabels": {%q= `<span style="color: #D15757">`+outErr.Error()+`</span>` %}
|
||||
{%code hasError = true %}
|
||||
{% endif %}
|
||||
}
|
||||
"steps": [
|
||||
{% for i, ds := range dss %}
|
||||
{% code
|
||||
inLabels, inErr := promutil.NewLabelsFromString(ds.In)
|
||||
outLabels, outErr := promutil.NewLabelsFromString(ds.Out)
|
||||
changedLabels := getChangedLabelNames(inLabels, outLabels)
|
||||
%}
|
||||
{
|
||||
"inLabels": {%q= labelsWithHighlight(inLabels, changedLabels, "#D15757") %},
|
||||
"outLabels": {%q= labelsWithHighlight(outLabels, changedLabels, "#4495e0") %},
|
||||
"rule": {%q= ds.Rule %},
|
||||
"errors": {
|
||||
{% if inErr != nil %}
|
||||
"inLabels": {%q= `<span style="color: #D15757">`+inErr.Error()+`</span>` %}{% if outErr != nil %},{% endif %}
|
||||
{%code hasError = true %}
|
||||
{% else %}
|
||||
{% endif %}
|
||||
{% if outErr != nil %}
|
||||
"outLabels": {%q= `<span style="color: #D15757">`+outErr.Error()+`</span>` %}
|
||||
{%code hasError = true %}
|
||||
{% endif %}
|
||||
}
|
||||
}
|
||||
{% if i != len(dss)-1 %},{% endif %}
|
||||
{% endfor %}
|
||||
]
|
||||
{% if len(dss) > 0 && !hasError %}
|
||||
,
|
||||
"originalLabels": {%q= mustFormatLabels(dss[0].In) %},
|
||||
"resultingLabels": {%q= mustFormatLabels(dss[len(dss)-1].Out) %}
|
||||
{% endif %}
|
||||
}
|
||||
{% if i != len(dss)-1 %},{% endif %}
|
||||
{% if idx != len(dsss)-1 %},{% endif %}
|
||||
{% endfor %}
|
||||
]
|
||||
{% if len(dss) > 0 && !hasError %}
|
||||
,
|
||||
"originalLabels": {%q= mustFormatLabels(dss[0].In) %},
|
||||
"resultingLabels": {%q= mustFormatLabels(dss[len(dss)-1].Out) %}
|
||||
{% endif %}
|
||||
{% endif %}
|
||||
}
|
||||
{% endfunc %}
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user