14 lines
483 B
YAML
14 lines
483 B
YAML
# This tells Benthos: Use the 'sql_poller' template as the input
|
|
input:
|
|
sql_poller:
|
|
dsn: "postgres://yugabyte@yugabytedb-2:5433/yugabyte?sslmode=disable"
|
|
table_name: "request_logs"
|
|
id_column: "received_at" # Or 'id' if you use the hashed string
|
|
|
|
# The output sends the polled data back to NATS
|
|
# output:
|
|
# nats_jetstream:
|
|
# urls: [ "nats:4222" ]
|
|
# subject: "public.request_logs"
|
|
# stream: "fact_stream"
|
|
# manage_stream: true # This is the key setting |