Substreams Sink 数据库变更

substreams-sink-database-changes 包含了子流可以发出的所有数据库变更的定义。

使用

• substreams-sink-postgres
• substreams-sink-mongodb

安装

# The Rust crate is named substreams-database-change for historical reasons
cargo add substreams-database-change

快速入门

Cargo.toml

[dependencies]
substreams = "0.5"
substreams-database-change = "1.0"

src/lib.rs

use substreams::errors::Error;
use substreams_database_change::pb::database::{DatabaseChanges, table_change::Operation};

#[substreams::handlers::map]
fn db_out(
    ... some stores ...
) -> Result<DatabaseChanges, Error> {
    // Initialize Database Changes container
    let mut database_changes: DatabaseChanges = Default::default();

    // Push change
    database_changes.push_change("transfer", "primary-key", 0, Operation::Create)
        .change("key1", ("previous1", "value1"))
        .change("key2", ("previous2", "value2"));

    Ok(database_changes)
}

重新生成 Protobuf

确保已安装 buf CLI（《https://buf.build/docs/installation/》）并运行

buf generate proto