fix: update chat OpenTelemetry Collector config to handle loguru serialized format
This commit is contained in:
parent
60b92b54a4
commit
3bdc14c330
@ -53,6 +53,9 @@ spec:
|
|||||||
- type: json_parser
|
- type: json_parser
|
||||||
parse_from: body
|
parse_from: body
|
||||||
parse_to: attributes
|
parse_to: attributes
|
||||||
|
- type: move
|
||||||
|
from: attributes.text
|
||||||
|
to: body
|
||||||
processors:
|
processors:
|
||||||
resource:
|
resource:
|
||||||
attributes:
|
attributes:
|
||||||
@ -78,23 +81,13 @@ spec:
|
|||||||
log_statements:
|
log_statements:
|
||||||
- context: log
|
- context: log
|
||||||
statements:
|
statements:
|
||||||
- set(resource.attributes["application"], log.attributes["context"]["app"])
|
- set(resource.attributes["application"], "chat")
|
||||||
- set(resource.attributes["environment"], log.attributes["context"]["env"])
|
- set(resource.attributes["environment"], "alpha")
|
||||||
- set(resource.attributes["kubernetes_node_name"], resource.attributes["k8s.node.name"])
|
- set(resource.attributes["kubernetes_node_name"], resource.attributes["k8s.node.name"])
|
||||||
- set(resource.attributes["kubernetes_pod_name"], resource.attributes["k8s.pod.name"])
|
- set(resource.attributes["kubernetes_pod_name"], resource.attributes["k8s.pod.name"])
|
||||||
- set(resource.attributes["kubernetes_pod_ip"], resource.attributes["k8s.pod.ip"])
|
- set(resource.attributes["kubernetes_pod_ip"], resource.attributes["k8s.pod.ip"])
|
||||||
- set(resource.attributes["kubernetes_deployment_name"], resource.attributes["k8s.deployment.name"])
|
- set(resource.attributes["kubernetes_deployment_name"], resource.attributes["k8s.deployment.name"])
|
||||||
- set(resource.attributes["kubernetes_namespace"], resource.attributes["k8s.namespace.name"])
|
- set(resource.attributes["kubernetes_namespace"], resource.attributes["k8s.namespace.name"])
|
||||||
- set(resource.attributes["body_json"], ParseJSON(log.body))
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["pod"], resource.attributes["k8s.pod.name"])
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["namespace"], resource.attributes["k8s.namespace.name"])
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["pod_ip"], resource.attributes["k8s.pod.ip"])
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["pod_uid"], resource.attributes["k8s.pod.uid"])
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["deployment"], resource.attributes["k8s.deployment.name"])
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["node"], resource.attributes["k8s.node.name"])
|
|
||||||
- set(resource.attributes["body_json"]["kubernetes"]["namespace"], resource.attributes["k8s.namespace.name"])
|
|
||||||
- set(log.body, resource.attributes["body_json"])
|
|
||||||
- delete_key(resource.attributes, "body_json")
|
|
||||||
batch:
|
batch:
|
||||||
send_batch_size: 5
|
send_batch_size: 5
|
||||||
timeout: 10s
|
timeout: 10s
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user