Azure Event Hub receiver Semantic Convention translator

pkg/translator/azure/property_names.go

@@ -0,0 +1,51 @@
+package azure
+
+var mappings = map[string]map[string]string{
+	"common": {},
+	"FrontDoorAccessLog": {
+		"trackingReference":   "",
+		"httpMethod":          "http.request.method",
+		"httpVersion":         "http.request.version",
+		"requestUri":          "url.full",
+		"hostName":            "server.address",
+		"requestBytes":        "http.request.body.size",
+		"responseBytes":       "http.response.body.size",
+		"userAgent":           "user_agent.original",
+		"clientIp":            "client.address",
+		"clientPort":          "client.port",
+		"socketIp":            "socket.address",
+		"timeTaken":           "http.server.request.duration",
+		"requestProtocol":     "",
+		"securityProtocol":    "",
+		"securityCipher":      "",
+		"securityCurves":      "",
+		"endpoint":            "",
+		"httpStatusCode":      "http.response.status_code",
+		"pop":                 "",
+		"cacheStatus":         "",
+		"matchedRulesSetName": "",
+		"routeName":           "http.route",
+		"referrer":            "http.request.header.referer",
+		"timeToFirstByte":     "",
+		"errorInfo":           "",
+		"originURL":           "",
+		"originIP":            "",
+		"originName":          "",
+		"result":              "",
+		"sni":                 "",
+	},
+}
+
+func ResourceLogKeyToSemConvKey(azName string, category string) (string, bool) {
+	if mapping := mappings[category]; mapping != nil {
+		if mapped := mapping[azName]; mapped != "" {
+			return mapped, true
+		}
+	}
+
+	if name := mappings["common"][azName]; name != "" {
+		return name, true
+	}
+
+	return "", false
+}

pkg/translator/azure/resourcelogs_to_logs.go

@@ -192,9 +192,11 @@ func extractRawAttributes(log azureLogRecord) map[string]any {
 	}
 	attrs[azureOperationName] = log.OperationName
 	setIf(attrs, azureOperationVersion, log.OperationVersion)
+
 	if log.Properties != nil {
-		attrs[azureProperties] = *log.Properties
+		copyProperties(log.Category, log.Properties, attrs)
 	}
+
 	setIf(attrs, azureResultDescription, log.ResultDescription)
 	setIf(attrs, azureResultSignature, log.ResultSignature)
 	setIf(attrs, azureResultType, log.ResultType)
@@ -207,6 +209,22 @@ func extractRawAttributes(log azureLogRecord) map[string]any {
 	return attrs
 }
 
+func copyProperties(category string, properties *any, attrs map[string]any) {
+	pmap := (*properties).(map[string]any)
+	var attrsProps map[string]any = nil
+	for k, v := range pmap {
+		if otelKey, found := ResourceLogKeyToSemConvKey(k, category); found {
+			attrs[otelKey] = v
+		} else {
+			if attrsProps == nil {
+				attrsProps = map[string]any{}
+				attrs["azure.properties"] = attrsProps
+			}
+			attrsProps[k] = v
+		}
+	}
+}
+
 func setIf(attrs map[string]any, key string, value *string) {
 	if value != nil && *value != "" {
 		attrs[key] = *value