feat(postgres sink): Add postgres sink

.github/actions/spelling/expect.txt

@@ -1019,6 +1019,7 @@ splitn
 SPOF
 spog
 springframework
+sqlx
 srcport
 SREs
 sret

Cargo.toml

@@ -342,6 +342,7 @@ smallvec = { version = "1", default-features = false, features = ["union", "serd
 snafu = { version = "0.7.5", default-features = false, features = ["futures", "std"] }
 snap = { version = "1.1.1", default-features = false }
 socket2 = { version = "0.5.7", default-features = false }
+sqlx = { version = "0.8.2", default-features= false, features = ["derive", "postgres", "runtime-tokio"], optional=true }
 stream-cancel = { version = "0.8.2", default-features = false }
 strip-ansi-escapes = { version = "0.2.0", default-features = false }
 syslog = { version = "6.1.1", default-features = false, optional = true }
@@ -699,6 +700,7 @@ sinks-logs = [
   "sinks-new_relic_logs",
   "sinks-new_relic",
   "sinks-papertrail",
+  "sinks-postgres",
   "sinks-pulsar",
   "sinks-redis",
   "sinks-sematext",
@@ -765,6 +767,7 @@ sinks-new_relic_logs = ["sinks-http"]
 sinks-new_relic = []
 sinks-papertrail = ["dep:syslog"]
 sinks-prometheus = ["dep:base64", "vector-lib/prometheus"]
+sinks-postgres = ["dep:sqlx"]
 sinks-pulsar = ["dep:apache-avro", "dep:pulsar", "dep:lru"]
 sinks-redis = ["dep:redis"]
 sinks-sematext = ["sinks-elasticsearch", "sinks-influxdb"]
@@ -812,6 +815,7 @@ all-integration-tests = [
   "nginx-integration-tests",
   "opentelemetry-integration-tests",
   "postgresql_metrics-integration-tests",
+  "postgres-integration-tests",
   "prometheus-integration-tests",
   "pulsar-integration-tests",
   "redis-integration-tests",
@@ -877,6 +881,7 @@ nats-integration-tests = ["sinks-nats", "sources-nats"]
 nginx-integration-tests = ["sources-nginx_metrics"]
 opentelemetry-integration-tests = ["sources-opentelemetry"]
 postgresql_metrics-integration-tests = ["sources-postgresql_metrics"]
+postgres-integration-tests = ["sinks-postgres"]
 prometheus-integration-tests = ["sinks-prometheus", "sources-prometheus", "sinks-influxdb"]
 pulsar-integration-tests = ["sinks-pulsar", "sources-pulsar"]
 redis-integration-tests = ["sinks-redis", "sources-redis"]

changelog.d/15765_postgres_sink.feature.md

@@ -0,0 +1,3 @@
+Add a new postgres sink which allows to send log events to a postgres database.
+
+authors: jorgehermo9

scripts/integration/postgres/test.yaml

@@ -1,5 +1,6 @@
 features:
 - postgresql_metrics-integration-tests
+- postgres-integration-tests
 
 test_filter: ::postgres
 
@@ -18,6 +19,7 @@ matrix:
 # expressions are evaluated using https://github.com/micromatch/picomatch
 paths:
 - "src/internal_events/postgresql_metrics.rs"
+- "src/sinks/postgres/**"
 - "src/sources/postgresql_metrics.rs"
 - "src/sources/util/**"
 - "scripts/integration/postgres/**"

src/sinks/mod.rs

@@ -81,6 +81,8 @@ pub mod new_relic;
 pub mod opendal_common;
 #[cfg(feature = "sinks-papertrail")]
 pub mod papertrail;
+#[cfg(feature = "sinks-postgres")]
+pub mod postgres;
 #[cfg(feature = "sinks-prometheus")]
 pub mod prometheus;
 #[cfg(feature = "sinks-pulsar")]