Add middleware.io specific resource attributes for cloudwatchreceiver

middleware-labs · Jun 10, 2024 · 444d8f9 · 444d8f9
1 parent 2890636
commit 444d8f9
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 1 deletion.
diff --git a/receiver/awscloudwatchreceiver/go.mod b/receiver/awscloudwatchreceiver/go.mod
@@ -17,6 +17,7 @@ require (
 	go.opentelemetry.io/collector/consumer v0.84.0
 	go.opentelemetry.io/collector/pdata v1.0.0-rcv0014
 	go.opentelemetry.io/collector/receiver v0.84.0
+	go.opentelemetry.io/collector/semconv v0.84.0
 	go.uber.org/zap v1.25.0
 )
 

diff --git a/receiver/awscloudwatchreceiver/go.sum b/receiver/awscloudwatchreceiver/go.sum
diff --git a/receiver/awscloudwatchreceiver/logs.go b/receiver/awscloudwatchreceiver/logs.go
@@ -17,6 +17,8 @@ import (
 	"go.opentelemetry.io/collector/pdata/pcommon"
 	"go.opentelemetry.io/collector/pdata/plog"
 	"go.uber.org/zap"
+
+	conventions "go.opentelemetry.io/collector/semconv/v1.6.1"
 )
 
 const (
@@ -275,9 +277,15 @@ func (l *logsReceiver) processEvents(now pcommon.Timestamp, logGroupName string,
 			rl := logs.ResourceLogs().AppendEmpty()
 			resourceLogs = &rl
 			resourceAttributes := resourceLogs.Resource().Attributes()
-			resourceAttributes.PutStr("aws.region", l.region)
+			resourceAttributes.PutStr(conventions.AttributeCloudProvider, conventions.AttributeCloudProviderAWS)
+			resourceAttributes.PutStr(conventions.AttributeCloudRegion, l.region)
 			resourceAttributes.PutStr("cloudwatch.log.group.name", logGroupName)
 			resourceAttributes.PutStr("cloudwatch.log.stream", logStreamName)
+
+			//middleware.io specific attributes
+			resourceAttributes.PutStr("channel", conventions.AttributeCloudProviderAWS)
+			resourceAttributes.PutStr("aws.scraping_approach", "api_polling")
+			resourceAttributes.PutStr("aws.polling_approach", l.pollingApproach)
 			group[logStreamName] = resourceLogs
 
 			// Ensure one scopeLogs is initialized so we can handle in standardized way going forward.