Source: stdin / File

The stdin source reads line-delimited JSON from standard input or a file and delivers each line as a message into a pg_tide inbox. This is useful for testing, replay from log files, data migration, and piping output from external commands into your inbox.

Configuration

SELECT tide.relay_set_inbox(
    'file-import',
    'imported_events',
    '{
        "source_type": "stdin",
        "input_file": "/data/events-export.jsonl",
        "batch_size": 1000
    }'::jsonb
);

Configuration Reference

Use Cases

Replaying from a log file

pg-tide --postgres-url "..." < events-backup.jsonl

Piping from another tool

kafka-console-consumer --topic events --from-beginning | pg-tide --postgres-url "..."

Further Reading

• Sinks: stdout — Writing to stdout (forward direction)
• Dry-Run & Replay — Replay mode for reprocessing