Skip to content

Commit ca1d01e

Browse files
committed
add parsing of traefik logs
1 parent a542433 commit ca1d01e

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

services/logging/vector.yaml

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ transforms:
2727
2828
# Extract structured log fields from message using regex pattern
2929
if exists(.message) {
30+
# python service logs
3031
parsed_fields, err = parse_regex(.message, r'log_level=(?P<log_level>[^|]*) \| log_timestamp=(?P<log_timestamp>[^|]*) \| log_source=(?P<log_source>[^|]*) \| log_uid=(?P<log_uid>[^|]*) \| log_oec=(?P<log_oec>[^|]*) \| log_trace_id=(?P<log_trace_id>[^|]*) \| log_span_id=(?P<log_span_id>[^|]*) \| log_msg=(?P<log_msg>.*)$')
3132
if err == null {
3233
.log_level = parsed_fields.log_level
@@ -38,6 +39,13 @@ transforms:
3839
.log_span_id = parsed_fields.log_span_id
3940
.log_msg = parsed_fields.log_msg
4041
}
42+
# traefik logs
43+
traefik_fields, traefik_err = parse_regex(.message, r'time="(?P<log_timestamp>[^"]*)" level=(?P<log_level>\w+) msg="(?P<log_msg>.*)"')
44+
if traefik_err == null {
45+
.log_timestamp = traefik_fields.log_timestamp
46+
.log_level = traefik_fields.log_level
47+
.log_msg = traefik_fields.log_msg
48+
}
4149
}
4250
4351
# Handle container name - GELF uses _container_name (with underscore prefix)

0 commit comments

Comments
 (0)