influxdata/telegraf

Variable schema for postgressql output plugin

Open

#16747 opened on Apr 9, 2025

View on GitHub
 (1 comment) (0 reactions) (0 assignees)Go (9,892 stars) (4,161 forks)batch import
feature requesthelp wantedsize/s

Description

Use Case

I have a PostgresSQL DB with several schemas. schemaA, schemaB, etc., in which I feed data from sensors through the mqtt_consumer plugin.

After a bit of processing, the measurement names look like "correspondingSchema_sensorName"

Expected behavior

I would like to be able to set the schema-name from a tag, which I would drop afterwards.

Actual behavior

Right now I have to define several outputs, one for each schema:

[[outputs.postgresql]]
namepass = ["schemaA_*"]
schema = "schemaA"

[[outputs.postgresql]]
namepass = ["schemaB_*"]
schema = "schemaB"

Additional info

No response

Contributor guide

Tech stack
go
Domain
backenddatabase
Issue type
feature
DifficultyEstimated implementation difficulty for a new contributor, from 1 for very small changes to 5 for expert-level work.
3
Estimated timeA rough time range for an experienced contributor to investigate, implement, test, and prepare a pull request.
half day
Activity statusHow available the issue appears right now: fresh, active, stale, blocked, or waiting on maintainer input.
fresh
ClarityHow clearly the issue explains the expected change, acceptance criteria, and next step.
mostly clear
Prerequisites
GoTelegraf plugin developmentPostgreSQL basics
Newbie friendlinessA 1-100 score estimating how approachable this issue is for first-time contributors.
35
Research direction
Investigate the existing PostgreSQL output plugin in plugins/outputs/postgresql/ to understand how schema is configured. Look for patterns in other output plugins that support dynamic configuration from tags (e.g., influxdb output might have similar). The issue suggests adding a way to set schema from a tag, possibly by modifying the output plugin to accept a tag key for schema and using the value in INSERT statements. Consider maintaining backward compatibility.