vector.yaml aktualisiert
This commit is contained in:
+5
-5
@@ -9,6 +9,8 @@ sources:
|
|||||||
# TRANSFORMS: Verarbeitung der Daten
|
# TRANSFORMS: Verarbeitung der Daten
|
||||||
# =============================================================================
|
# =============================================================================
|
||||||
transforms:
|
transforms:
|
||||||
|
# Wir lassen den filter_debug-Block zwar stehen,
|
||||||
|
# aber wir nehmen ihn aus der Kette raus.
|
||||||
filter_debug:
|
filter_debug:
|
||||||
type: filter
|
type: filter
|
||||||
inputs: [docker_logs]
|
inputs: [docker_logs]
|
||||||
@@ -16,13 +18,11 @@ transforms:
|
|||||||
|
|
||||||
parse_logs:
|
parse_logs:
|
||||||
type: remap
|
type: remap
|
||||||
inputs: [filter_debug]
|
# ÄNDERUNG HIER: Wir nehmen die Daten DIREKT von der Source,
|
||||||
|
# nicht mehr vom Filter!
|
||||||
|
inputs: [docker_logs]
|
||||||
source: |
|
source: |
|
||||||
# HIER IST DIE ÄNDERUNG:
|
|
||||||
# Das ', err' fängt den Fehler ab, falls .message kein String ist.
|
|
||||||
# Wenn es fehlschlägt, bleibt .message einfach so, wie es war.
|
|
||||||
.message, err = replace(.message, "\n", "")
|
.message, err = replace(.message, "\n", "")
|
||||||
|
|
||||||
.service = "my-cluster"
|
.service = "my-cluster"
|
||||||
|
|
||||||
# =============================================================================
|
# =============================================================================
|
||||||
|
|||||||
Reference in New Issue
Block a user