[scraper/scraperhelper] Add scraper ID to error logs (#14461)

<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue.
Ex. Adding a feature - Explain what this achieves.-->
#### Description

This PR adds the `scraperID` to the error logs for scrapers (metrics,
logs, and profiles). Why is this important?

Currently if an error occurs in any of the scrapers in
`hostmetricsreceiver/internal/scraper/...` there is no info about the
which scraper errored in the logs:

```bash
2026-01-21T10:42:42.830Z	error	[email protected]/obs_metrics.go:61	Error scraping metrics	{"resource": {"service.instance.id": "63071771-056d-40ca-83e3-585dc1a00d57", "service.name": "otelcontribcol", "service.version": "0.144.0-dev"}, "otelcol.component.id": "hostmetrics", "otelcol.component.kind": "receiver", "otelcol.signal": "metrics", "error": "forced test error for scraper identification"}
```

The update in this PR add's the scraper ID (In this case the memory
scraper errored) to the logs which then gives us:

```bash
2026-01-21T10:23:52.759Z	error	scraperhelper/obs_metrics.go:62	Error scraping metrics	{"resource": {"service.instance.id": "7137f19d-706f-4095-8367-0d68b2732402", "service.name": "otelcontribcol", "service.version": "0.144.0-dev"}, "otelcol.component.id": "hostmetrics", "otelcol.component.kind": "receiver", "otelcol.signal": "metrics", "scraper": "memory", "error": "forced test error for scraper identification"}
```

<!-- Issue number if applicable -->
#### Link to tracking issue
Fixes Issue in
[collector-contrib](open-telemetry/opentelemetry-collector-contrib#35814 (comment)).

<!--Describe what testing was performed and which tests were added.-->
#### Testing

**Metrics scrapers:** Locally tested with `collector-contrib` by
updating the mod file...
**Logs scrapers:** The same pattern was applied. Logs scrapers (MySQL,
PostgreSQL, Oracle, SQL Server receivers) require database connections
for integration testing.
**Profiles scrapers (xscraperhelper):** The same pattern was applied.
Note: There are currently no profiles scrapers in collector-contrib to
test against.

**Metrics scraper local test**: Locally this was updated and included in
the `collector-contrib` via updating the mod file. An error was forced
in the `hostmetricsreceiver/internal/scraper/...` both memory and cpu,
we can now see which scraper component had an error:

```bash
2026-01-21T11:51:34.176Z	error	scraperhelper/obs_metrics.go:61	Error scraping metrics	{"resource": {"service.instance.id": "e6832705-bc54-43dd-9b1f-0c06d58b7ead", "service.name": "otelcontribcol", "service.version": "0.144.0-dev"}, "otelcol.component.id": "hostmetrics", "otelcol.component.kind": "receiver", "otelcol.signal": "metrics", "scraper": "memory", "error": "forced test error for scraper identification"}
go.opentelemetry.io/collector/scraper/scraperhelper.wrapObsMetrics.func1
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/obs_metrics.go:61
go.opentelemetry.io/collector/scraper.ScrapeMetricsFunc.ScrapeMetrics
	/home/dos/go/pkg/mod/go.opentelemetry.io/collector/[email protected]/metrics.go:24
go.opentelemetry.io/collector/scraper/scraperhelper.scrapeMetrics
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/controller.go:167
go.opentelemetry.io/collector/scraper/scraperhelper.NewMetricsController.func1
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/controller.go:139
go.opentelemetry.io/collector/scraper/scraperhelper/internal/controller.(*Controller[...]).startScraping.func1
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/internal/controller/controller.go:118
2026-01-21T11:51:34.177Z	error	scraperhelper/obs_metrics.go:61	Error scraping metrics	{"resource": {"service.instance.id": "e6832705-bc54-43dd-9b1f-0c06d58b7ead", "service.name": "otelcontribcol", "service.version": "0.144.0-dev"}, "otelcol.component.id": "hostmetrics", "otelcol.component.kind": "receiver", "otelcol.signal": "metrics", "scraper": "cpu", "error": "forced test error for scraper identification"}
go.opentelemetry.io/collector/scraper/scraperhelper.wrapObsMetrics.func1
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/obs_metrics.go:61
go.opentelemetry.io/collector/scraper.ScrapeMetricsFunc.ScrapeMetrics
	/home/dos/go/pkg/mod/go.opentelemetry.io/collector/[email protected]/metrics.go:24
go.opentelemetry.io/collector/scraper/scraperhelper.scrapeMetrics
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/controller.go:167
go.opentelemetry.io/collector/scraper/scraperhelper.NewMetricsController.func1
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/controller.go:139
go.opentelemetry.io/collector/scraper/scraperhelper/internal/controller.(*Controller[...]).startScraping.func1
	/home/dos/Documents/opentelemetry-collector/scraper/scraperhelper/internal/controller/controller.go:118
2026-01-21T11:51:34.199Z	info	Metrics	{"resource": {"service.instance.id": "e6832705-bc54-43dd-9b1f-0c06d58b7ead", "service.name": "otelcontribcol", "service.version": "0.144.0-dev"}, "otelcol.component.id": "debug", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "resource metrics": 1, "metrics": 1, "data points": 1}
2026-01-21T11:51:34.199Z	info	ResourceMetrics #0
Resource SchemaURL: https://opentelemetry.io/schemas/1.9.0

```

Closes
open-telemetry/opentelemetry-collector-contrib#35814

Author: osullivandonal

.chloggen/add-scraperID-to-error-logs.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: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. receiver/otlp)
+component: pkg/scraperhelper
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: ScraperID has been added to the logs for metrics, logs, and profiles
+
+# One or more tracking issues or pull requests related to the change
+issues: [14461]

scraper/scraperhelper/controller_test.go

@@ -16,6 +16,8 @@ import (
 	"go.opentelemetry.io/otel/sdk/metric/metricdata/metricdatatest"
 	sdktrace "go.opentelemetry.io/otel/sdk/trace"
 	"go.uber.org/multierr"
+	"go.uber.org/zap"
+	"go.uber.org/zap/zaptest/observer"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/component/componenttest"
@@ -763,3 +765,59 @@ func TestNewDefaultControllerConfig(t *testing.T) {
 	intControllerConfig := controller.NewDefaultControllerConfig()
 	require.Equal(t, intControllerConfig, controllerConfig)
 }
+
+func TestNewMetricsController_ScraperIDInErrorLogs(t *testing.T) {
+	t.Parallel()
+
+	core, observedLogs := observer.New(zap.ErrorLevel)
+	tel := componenttest.NewTelemetry()
+	t.Cleanup(func() { require.NoError(t, tel.Shutdown(context.Background())) })
+	telset := tel.NewTelemetrySettings()
+	telset.Logger = zap.New(core)
+
+	receiverID := component.MustNewID("fakeReceiver")
+	scraperType := component.MustNewType("fakeScraper")
+	scrapeErr := errors.New("scrape error")
+
+	scrapeCh := make(chan int, 1)
+	ts := &testScrape{ch: scrapeCh, err: scrapeErr}
+	scp, err := scraper.NewMetrics(ts.scrapeMetrics)
+	require.NoError(t, err)
+
+	cfg := newTestNoDelaySettings()
+	tickerCh := make(chan time.Time)
+
+	recv, err := NewMetricsController(
+		cfg,
+		receiver.Settings{ID: receiverID, TelemetrySettings: telset, BuildInfo: component.NewDefaultBuildInfo()},
+		new(consumertest.MetricsSink),
+		AddMetricsScraper(scraperType, scp),
+		WithTickerChannel(tickerCh),
+	)
+	require.NoError(t, err)
+	require.NoError(t, recv.Start(context.Background(), componenttest.NewNopHost()))
+	defer func() { require.NoError(t, recv.Shutdown(context.Background())) }()
+
+	<-scrapeCh
+
+	require.Eventually(t, func() bool {
+		return observedLogs.Len() >= 1
+	}, time.Second, 10*time.Millisecond)
+	errorLogs := observedLogs.FilterLevelExact(zap.ErrorLevel).All()
+	require.Len(t, errorLogs, 1)
+
+	assert.Equal(t, "Error scraping metrics", errorLogs[0].Message)
+	assert.Equal(t, scraperType.String(), errorLogs[0].ContextMap()["scraper"])
+	assert.Equal(t, scrapeErr.Error(), errorLogs[0].ContextMap()["error"])
+
+	// Verify the original receiver telemetry settings logger was NOT mutated
+	// by logging something and checking it doesn't have the scraper field
+	telset.Logger.Error("test log from receiver")
+
+	allLogs := observedLogs.FilterLevelExact(zap.ErrorLevel).All()
+	require.Len(t, allLogs, 2)
+
+	receiverLog := allLogs[1]
+	assert.Equal(t, "test log from receiver", receiverLog.Message)
+	assert.NotContains(t, receiverLog.ContextMap(), "scraper")
+}

scraper/scraperhelper/internal/controller/controller.go

@@ -11,6 +11,7 @@ import (
 	"time"
 
 	"go.uber.org/multierr"
+	"go.uber.org/zap"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/receiver"
@@ -124,9 +125,12 @@ func (sc *Controller[T]) startScraping() {
 }
 
 func GetSettings(sType component.Type, rSet receiver.Settings) scraper.Settings {
+	id := component.NewID(sType)
+	telemetry := rSet.TelemetrySettings
+	telemetry.Logger = telemetry.Logger.With(zap.String("scraper", id.String()))
 	return scraper.Settings{
-		ID:                component.NewID(sType),
-		TelemetrySettings: rSet.TelemetrySettings,
+		ID:                id,
+		TelemetrySettings: telemetry,
 		BuildInfo:         rSet.BuildInfo,
 	}
 }

scraper/scraperhelper/obs_logs_test.go

@@ -14,12 +14,16 @@ import (
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/sdk/metric/metricdata"
 	"go.opentelemetry.io/otel/sdk/metric/metricdata/metricdatatest"
+	"go.uber.org/zap"
+	"go.uber.org/zap/zaptest/observer"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/component/componenttest"
 	"go.opentelemetry.io/collector/pdata/plog"
 	"go.opentelemetry.io/collector/pdata/testdata"
+	"go.opentelemetry.io/collector/receiver"
 	"go.opentelemetry.io/collector/scraper"
+	"go.opentelemetry.io/collector/scraper/scraperhelper/internal/controller"
 	"go.opentelemetry.io/collector/scraper/scraperhelper/internal/metadatatest"
 )
 
@@ -97,6 +101,36 @@ func TestCheckScraperLogs(t *testing.T) {
 	checkScraperLogs(t, tel, receiverID, scraperID, 7, 0)
 }
 
+func TestScrapeLogsDataOp_LogsScraperID(t *testing.T) {
+	tel := componenttest.NewTelemetry()
+	t.Cleanup(func() { require.NoError(t, tel.Shutdown(context.Background())) })
+
+	core, observedLogs := observer.New(zap.ErrorLevel)
+	telset := tel.NewTelemetrySettings()
+	telset.Logger = zap.New(core)
+
+	rSet := receiver.Settings{
+		ID:                receiverID,
+		TelemetrySettings: telset,
+	}
+	set := controller.GetSettings(scraperID.Type(), rSet)
+
+	sm, err := scraper.NewLogs(func(context.Context) (plog.Logs, error) {
+		return plog.NewLogs(), errFake
+	})
+	require.NoError(t, err)
+	sf, err := wrapObsLogs(sm, receiverID, scraperID, set.TelemetrySettings)
+	require.NoError(t, err)
+	_, err = sf.ScrapeLogs(context.Background())
+	require.ErrorIs(t, err, errFake)
+
+	errorLogs := observedLogs.FilterLevelExact(zap.ErrorLevel).All()
+	require.Len(t, errorLogs, 1)
+	assert.Equal(t, "Error scraping logs", errorLogs[0].Message)
+	assert.Equal(t, scraperID.String(), errorLogs[0].ContextMap()["scraper"])
+	assert.Equal(t, errFake.Error(), errorLogs[0].ContextMap()["error"])
+}
+
 func checkScraperLogs(t *testing.T, tel *componenttest.Telemetry, receiver, scraper component.ID, scrapedLogRecords, erroredLogRecords int64) {
 	metadatatest.AssertEqualScraperScrapedLogRecords(t, tel,
 		[]metricdata.DataPoint[int64]{

scraper/scraperhelper/obs_metrics_test.go

@@ -14,13 +14,17 @@ import (
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/sdk/metric/metricdata"
 	"go.opentelemetry.io/otel/sdk/metric/metricdata/metricdatatest"
+	"go.uber.org/zap"
+	"go.uber.org/zap/zaptest/observer"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/component/componenttest"
 	"go.opentelemetry.io/collector/pdata/pmetric"
 	"go.opentelemetry.io/collector/pdata/testdata"
+	"go.opentelemetry.io/collector/receiver"
 	"go.opentelemetry.io/collector/scraper"
 	"go.opentelemetry.io/collector/scraper/scrapererror"
+	"go.opentelemetry.io/collector/scraper/scraperhelper/internal/controller"
 	"go.opentelemetry.io/collector/scraper/scraperhelper/internal/metadatatest"
 )
 
@@ -110,6 +114,36 @@ func TestCheckScraperMetrics(t *testing.T) {
 	checkScraperMetrics(t, tel, receiverID, scraperID, 7, 0)
 }
 
+func TestScrapeMetricsDataOp_LogsScraperID(t *testing.T) {
+	tel := componenttest.NewTelemetry()
+	t.Cleanup(func() { require.NoError(t, tel.Shutdown(context.Background())) })
+
+	core, observedLogs := observer.New(zap.ErrorLevel)
+	telset := tel.NewTelemetrySettings()
+	telset.Logger = zap.New(core)
+
+	rSet := receiver.Settings{
+		ID:                receiverID,
+		TelemetrySettings: telset,
+	}
+	set := controller.GetSettings(scraperID.Type(), rSet)
+
+	sm, err := scraper.NewMetrics(func(context.Context) (pmetric.Metrics, error) {
+		return pmetric.NewMetrics(), errFake
+	})
+	require.NoError(t, err)
+	sf, err := wrapObsMetrics(sm, receiverID, scraperID, set.TelemetrySettings)
+	require.NoError(t, err)
+	_, err = sf.ScrapeMetrics(context.Background())
+	require.ErrorIs(t, err, errFake)
+
+	errorLogs := observedLogs.FilterLevelExact(zap.ErrorLevel).All()
+	require.Len(t, errorLogs, 1)
+	assert.Equal(t, "Error scraping metrics", errorLogs[0].Message)
+	assert.Equal(t, scraperID.String(), errorLogs[0].ContextMap()["scraper"])
+	assert.Equal(t, errFake.Error(), errorLogs[0].ContextMap()["error"])
+}
+
 func checkScraperMetrics(t *testing.T, tt *componenttest.Telemetry, receiver, scraper component.ID, scrapedMetricPoints, erroredMetricPoints int64) {
 	metadatatest.AssertEqualScraperScrapedMetricPoints(t, tt,
 		[]metricdata.DataPoint[int64]{

scraper/scraperhelper/xscraperhelper/obs_profiles_test.go

@@ -15,12 +15,16 @@ import (
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/sdk/metric/metricdata"
 	"go.opentelemetry.io/otel/sdk/metric/metricdata/metricdatatest"
+	"go.uber.org/zap"
+	"go.uber.org/zap/zaptest/observer"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/component/componenttest"
 	"go.opentelemetry.io/collector/pdata/pprofile"
 	"go.opentelemetry.io/collector/pdata/testdata"
+	"go.opentelemetry.io/collector/receiver"
 	"go.opentelemetry.io/collector/scraper/scrapererror"
+	"go.opentelemetry.io/collector/scraper/scraperhelper/internal/controller"
 	"go.opentelemetry.io/collector/scraper/scraperhelper/xscraperhelper/internal/metadatatest"
 	"go.opentelemetry.io/collector/scraper/xscraper"
 )
@@ -112,6 +116,36 @@ func TestCheckScraperProfiles(t *testing.T) {
 	checkScraperProfiles(t, tel, receiverID, scraperID, 7, 0)
 }
 
+func TestScrapeProfilesDataOp_LogsScraperID(t *testing.T) {
+	tel := componenttest.NewTelemetry()
+	t.Cleanup(func() { require.NoError(t, tel.Shutdown(context.Background())) })
+
+	core, observedLogs := observer.New(zap.ErrorLevel)
+	telset := tel.NewTelemetrySettings()
+	telset.Logger = zap.New(core)
+
+	rSet := receiver.Settings{
+		ID:                receiverID,
+		TelemetrySettings: telset,
+	}
+	set := controller.GetSettings(scraperID.Type(), rSet)
+
+	sm, err := xscraper.NewProfiles(func(context.Context) (pprofile.Profiles, error) {
+		return pprofile.NewProfiles(), errFake
+	})
+	require.NoError(t, err)
+	sf, err := wrapObsProfiles(sm, receiverID, scraperID, set.TelemetrySettings)
+	require.NoError(t, err)
+	_, err = sf.ScrapeProfiles(context.Background())
+	require.ErrorIs(t, err, errFake)
+
+	errorLogs := observedLogs.FilterLevelExact(zap.ErrorLevel).All()
+	require.Len(t, errorLogs, 1)
+	assert.Equal(t, "Error scraping profiles", errorLogs[0].Message)
+	assert.Equal(t, scraperID.String(), errorLogs[0].ContextMap()["scraper"])
+	assert.Equal(t, errFake.Error(), errorLogs[0].ContextMap()["error"])
+}
+
 func checkScraperProfiles(t *testing.T, tel *componenttest.Telemetry, receiver, scraper component.ID, scrapedProfileRecords, erroredProfileRecords int64) {
 	metadatatest.AssertEqualScraperScrapedProfileRecords(t, tel,
 		[]metricdata.DataPoint[int64]{