Substreams Sink PostgreSQL

This is a command line tool to quickly sync a Substreams with a PostgreSQL database.

Quickstart

1. Install substreams-sink-postgres by using the pre-built binary release available in the releases page. Extract substreams-sink-postgres binary into a folder and ensure this folder is referenced globally via your PATH environment variable.

   Note Or install from source directly go install github.com/streamingfast/substreams-sink-postgres/cmd/substreams-sink-postgres@latest.

2. Start Docker Compose:

   docker compose up

   Note Feel free to skip this step if you already have a running Postgres instance accessible, don't forget to update the connection string in the command below.

3. Run the setup command:

   substreams-sink-postgres setup "psql://dev-node:insecure-change-me-in-prod@localhost:5432/dev-node?sslmode=disable" docs/tutorial/schema.sql

   This will connect to the given database pointed by psql://dev-node:insecure-change-me-in-prod@localhost:5432/dev-node?sslmode=disable, create the tables and indexes specified in the given <schema_file>, and will create the required tables to run the sink (e.g. the cursors table).

   Note For the sake of idempotency, we recommend that the schema file only contain create table if not exists statements.

4. Run the sink

   Compile the Substreams tutorial project first:

   cd docs/tutorial
   cargo build --target wasm32-unknown-unknown --release
   cd ../..

   Once the compilation has completed, let launch the sink process.

   Note To connect to Substreams you will need an authentication token, follow this guide to obtain one.

   substreams-sink-postgres run \
       "psql://dev-node:insecure-change-me-in-prod@localhost:5432/dev-node?sslmode=disable" \
       "mainnet.eth.streamingfast.io:443" \
       "./docs/tutorial/substreams.yaml" \
       db_out

Output Module

To be accepted by substreams-sink-postgres, your module output's type must be a sf.substreams.sink.database.v1.DatabaseChanges message. The Rust crate substreams-data-change contains bindings and helpers to implement it easily. Some project implementing db_out module for reference:

• substreams-eth-block-meta (some helpers found in db_out.rs)

By convention, we name the map module that emits sf.substreams.sink.database.v1.DatabaseChanges output db_out.

Note that using prior versions (0.2.0, 0.1.*) of substreams-database-change, you have to use substreams.database.v1.DatabaseChanges in your substreams.yaml and put the respected version of the spkg in your substreams.yaml

PostgreSQL DSN

The connection string is provided using a simple string format respecting the URL specification. The DSN format is:

psql://<user>:<password>@<host>/<dbname>[?<options>]

Where <options> is URL query parameters in <key>=<value> format, multiple options are separated by & signs. Supported options can be seen on libpq official documentation. The options <user>, <password>, <host> and <dbname> should not be passed in <options> as they are automatically extracted from the DSN URL.

Moreover, the schema option key can be used to select a particular schema within the <dbname> database.