Introduce datadogsemanticsprocessor component with mappings for OTLP-…

.chloggen/ibraheem_traces-only-dd-semantic-processor.yaml

@@ -0,0 +1,13 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: new_component
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: datadogsemanticsprocessor
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Add datadogsemanticsprocessor, which transforms OpenTelemetry semantic conventions to Datadog semantic conventions
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [35304]

.github/CODEOWNERS

@@ -179,6 +179,7 @@ pkg/xk8stest/                                                    @open-telemetry
 processor/attributesprocessor/                                   @open-telemetry/collector-contrib-approvers @boostchicken
 processor/coralogixprocessor/                                    @open-telemetry/collector-contrib-approvers @crobert-1 @povilasv
 processor/cumulativetodeltaprocessor/                            @open-telemetry/collector-contrib-approvers @TylerHelmuth
+processor/datadogsemanticsprocessor/                             @open-telemetry/collector-contrib-approvers @songy23 @IbraheemA @mx-psi @dineshg13 @ankitpatel96 @jade-guiton-dd @jackgopack4
 processor/deltatocumulativeprocessor/                            @open-telemetry/collector-contrib-approvers @sh0rez @RichieSams
 processor/deltatorateprocessor/                                  @open-telemetry/collector-contrib-approvers @Aneurysm9
 processor/filterprocessor/                                       @open-telemetry/collector-contrib-approvers @TylerHelmuth @boostchicken

.github/ISSUE_TEMPLATE/bug_report.yaml

@@ -182,6 +182,7 @@ body:
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta
+      - processor/datadogsemantics
       - processor/deltatocumulative
       - processor/deltatorate
       - processor/filter

.github/ISSUE_TEMPLATE/feature_request.yaml

@@ -176,6 +176,7 @@ body:
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta
+      - processor/datadogsemantics
       - processor/deltatocumulative
       - processor/deltatorate
       - processor/filter

.github/ISSUE_TEMPLATE/other.yaml

@@ -176,6 +176,7 @@ body:
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta
+      - processor/datadogsemantics
       - processor/deltatocumulative
       - processor/deltatorate
       - processor/filter

.github/ISSUE_TEMPLATE/unmaintained.yaml

@@ -181,6 +181,7 @@ body:
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta
+      - processor/datadogsemantics
       - processor/deltatocumulative
       - processor/deltatorate
       - processor/filter

cmd/otelcontribcol/builder-config.yaml

@@ -133,6 +133,7 @@ processors:
   - gomod: github.com/open-telemetry/opentelemetry-collector-contrib/processor/tailsamplingprocessor v0.121.0
   - gomod: github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor v0.121.0
   - gomod: github.com/open-telemetry/opentelemetry-collector-contrib/processor/remotetapprocessor v0.121.0
+  - gomod: github.com/open-telemetry/opentelemetry-collector-contrib/processor/datadogsemanticsprocessor v0.121.1
 
 receivers:
   - gomod: go.opentelemetry.io/collector/receiver/nopreceiver v0.121.1-0.20250307194215-7d3e03e500b0

internal/tidylist/tidylist.txt

@@ -199,6 +199,7 @@ pkg/winperfcounters
 processor/attributesprocessor
 processor/coralogixprocessor
 processor/cumulativetodeltaprocessor
+processor/datadogsemanticsprocessor
 processor/deltatocumulativeprocessor
 processor/deltatorateprocessor
 processor/filterprocessor

processor/datadogsemanticsprocessor/Makefile

@@ -0,0 +1 @@
+include ../../Makefile.Common

processor/datadogsemanticsprocessor/README.md

@@ -0,0 +1,12 @@
+# Datadog Semantics Processor
+<!-- status autogenerated section -->
+| Status        |           |
+| ------------- |-----------|
+| Stability     | [development]: traces   |
+| Distributions | [contrib] |
+| Issues        | [![Open issues](https://img.shields.io/github/issues-search/open-telemetry/opentelemetry-collector-contrib?query=is%3Aissue%20is%3Aopen%20label%3Aprocessor%2Fdatadogsemantics%20&label=open&color=orange&logo=opentelemetry)](https://github.com/open-telemetry/opentelemetry-collector-contrib/issues?q=is%3Aopen+is%3Aissue+label%3Aprocessor%2Fdatadogsemantics) [![Closed issues](https://img.shields.io/github/issues-search/open-telemetry/opentelemetry-collector-contrib?query=is%3Aissue%20is%3Aclosed%20label%3Aprocessor%2Fdatadogsemantics%20&label=closed&color=blue&logo=opentelemetry)](https://github.com/open-telemetry/opentelemetry-collector-contrib/issues?q=is%3Aclosed+is%3Aissue+label%3Aprocessor%2Fdatadogsemantics) |
+| [Code Owners](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/main/CONTRIBUTING.md#becoming-a-code-owner)    | [@songy23](https://www.github.com/songy23), [@IbraheemA](https://www.github.com/IbraheemA), [@mx-psi](https://www.github.com/mx-psi), [@dineshg13](https://www.github.com/dineshg13), [@ankitpatel96](https://www.github.com/ankitpatel96), [@jade-guiton-dd](https://www.github.com/jade-guiton-dd), [@jackgopack4](https://www.github.com/jackgopack4) |
+
+[development]: https://github.com/open-telemetry/opentelemetry-collector/blob/main/docs/component-stability.md#development
+[contrib]: https://github.com/open-telemetry/opentelemetry-collector-releases/tree/main/distributions/otelcol-contrib
+<!-- end autogenerated section -->

processor/datadogsemanticsprocessor/config.go

@@ -0,0 +1,13 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+package datadogsemanticsprocessor // import "github.com/open-telemetry/opentelemetry-collector-contrib/processor/datadogsemanticsprocessor"
+
+// Config defines configuration for Datadog semantics processor.
+type Config struct {
+	// OverrideIncomingDatadogFields specifies what is done with incoming Datadog fields.
+	// If it is false, any fields namespaced with "datadog." will pass through unchanged.
+	// If it is true, all fields in the "datadog." namespace will be recomputed by the processor.
+	// Default: false.
+	OverrideIncomingDatadogFields bool `mapstructure:"override_incoming_datadog_fields"`
+}

processor/datadogsemanticsprocessor/doc.go

@@ -0,0 +1,7 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+//go:generate mdatagen metadata.yaml
+
+// Package datadogsemanticsprocessor contains the logic to transform OpenTelemetry semantic conventions to Datadog semantic conventions.
+package datadogsemanticsprocessor // import "github.com/open-telemetry/opentelemetry-collector-contrib/processor/datadogsemanticsprocessor"

processor/datadogsemanticsprocessor/factory.go

@@ -0,0 +1,73 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+package datadogsemanticsprocessor // import "github.com/open-telemetry/opentelemetry-collector-contrib/processor/datadogsemanticsprocessor"
+
+import (
+	"context"
+
+	"github.com/DataDog/opentelemetry-mapping-go/pkg/otlp/attributes"
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/consumer"
+	"go.opentelemetry.io/collector/processor"
+	"go.opentelemetry.io/collector/processor/processorhelper"
+
+	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/datadogsemanticsprocessor/internal/metadata"
+)
+
+var consumerCapabilities = consumer.Capabilities{MutatesData: true}
+
+// NewFactory returns a new factory for the Datadog semantics processor.
+func NewFactory() processor.Factory {
+	return processor.NewFactory(
+		metadata.Type,
+		createDefaultConfig,
+		processor.WithTraces(createTracesProcessor, metadata.TracesStability),
+	)
+}
+
+type tracesProcessor struct {
+	overrideIncomingDatadogFields bool
+	attrsTranslator               *attributes.Translator
+}
+
+func newTracesProcessor(
+	set processor.Settings,
+	cfg *Config,
+) (*tracesProcessor, error) {
+	attrsTranslator, err := attributes.NewTranslator(set.TelemetrySettings)
+	if err != nil {
+		return nil, err
+	}
+	return &tracesProcessor{
+		overrideIncomingDatadogFields: cfg.OverrideIncomingDatadogFields,
+		attrsTranslator:               attrsTranslator,
+	}, nil
+}
+
+func createDefaultConfig() component.Config {
+	return &Config{
+		OverrideIncomingDatadogFields: false,
+	}
+}
+
+func createTracesProcessor(
+	ctx context.Context,
+	set processor.Settings,
+	cfg component.Config,
+	next consumer.Traces,
+) (processor.Traces, error) {
+	oCfg := cfg.(*Config)
+	tp, err := newTracesProcessor(set, oCfg)
+	if err != nil {
+		return nil, err
+	}
+	return processorhelper.NewTraces(
+		ctx,
+		set,
+		cfg,
+		next,
+		tp.processTraces,
+		processorhelper.WithCapabilities(consumerCapabilities),
+	)
+}