fix: support net.sock.peer.addr attribute for peer address parsing (#11800)

lzf575 · web-flow · commit 098b90254df1 · 2026-06-18T07:09:23.000Z
diff --git a/server/ingester/flow_log/log_data/otel_import.go b/server/ingester/flow_log/log_data/otel_import.go
@@ -211,7 +211,7 @@ func (h *L7FlowLog) fillAttributes(spanAttributes, resAttributes []*v11.KeyValue
 					h.Protocol = uint8(layers.IPProtocolUDP)
 				}
 			// https://github.com/open-telemetry/opentelemetry-go/blob/db7fd1bb51ce6ed1171cac15eeecb6871dbbb80a/semconv/internal/http.go#L79
-			case "net.peer.ip", "network.peer.address":
+			case "net.peer.ip", "network.peer.address", "net.sock.peer.addr":
 				if hasPeerAddress {
 					continue
 				}

Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ func (h L7FlowLog) fillAttributes(spanAttributes, resAttributes []v11.KeyValue`
`211`	`211`	`h.Protocol = uint8(layers.IPProtocolUDP)`
`212`	`212`	`}`
`213`	`213`	`// https://github.com/open-telemetry/opentelemetry-go/blob/db7fd1bb51ce6ed1171cac15eeecb6871dbbb80a/semconv/internal/http.go#L79`
`214`		`- case "net.peer.ip", "network.peer.address":`
	`214`	`+ case "net.peer.ip", "network.peer.address", "net.sock.peer.addr":`
`215`	`215`	`if hasPeerAddress {`
`216`	`216`	`continue`
`217`	`217`	`}`