fix(opentelemetry): enhance log body processing by restructuring Kubernetes attributes handling
Signed-off-by: zhenyus <zhenyus@mathmast.com>
This commit is contained in:
parent
6588193c7d
commit
ebeea26864
@ -85,14 +85,16 @@ spec:
|
|||||||
- 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(log.body["kubernetes"]["pod"], resource.attributes["k8s.pod.name"])
|
- set(resource.attributes["body_json"], ParseJSON(log.body))
|
||||||
- set(log.body["kubernetes"]["namespace"], resource.attributes["k8s.namespace.name"])
|
- set(resource.attributes["body_json"]["kubernetes"]["pod"], resource.attributes["k8s.pod.name"])
|
||||||
- set(log.body["kubernetes"]["pod_ip"], resource.attributes["k8s.pod.ip"])
|
- set(resource.attributes["body_json"]["kubernetes"]["namespace"], resource.attributes["k8s.namespace.name"])
|
||||||
- set(log.body["kubernetes"]["pod_uid"], resource.attributes["k8s.pod.uid"])
|
- set(resource.attributes["body_json"]["kubernetes"]["pod_ip"], resource.attributes["k8s.pod.ip"])
|
||||||
- set(log.body["kubernetes"]["deployment"], resource.attributes["k8s.deployment.name"])
|
- set(resource.attributes["body_json"]["kubernetes"]["pod_uid"], resource.attributes["k8s.pod.uid"])
|
||||||
- set(log.body["kubernetes"]["node"], resource.attributes["k8s.node.name"])
|
- set(resource.attributes["body_json"]["kubernetes"]["deployment"], resource.attributes["k8s.deployment.name"])
|
||||||
- set(log.body["kubernetes"]["namespace"], resource.attributes["k8s.namespace.name"])
|
- set(resource.attributes["body_json"]["kubernetes"]["node"], resource.attributes["k8s.node.name"])
|
||||||
batch:
|
- set(resource.attributes["body_json"]["kubernetes"]["namespace"], resource.attributes["k8s.namespace.name"])
|
||||||
|
- set(log.body, String(merge_maps(ParseJSON(log.body), resource.attributes["body_json"], "upsert")))
|
||||||
|
- delete_key(resource.attributes, "body_json")
|
||||||
send_batch_size: 5
|
send_batch_size: 5
|
||||||
timeout: 10s
|
timeout: 10s
|
||||||
exporters:
|
exporters:
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user