Crate faucet_source_snowflake 

faucet-source-snowflake

Snowflake query source connector for the faucet-stream ecosystem.

Executes a SQL statement against Snowflake via the SQL REST API and streams the result set as serde_json::Value records, one JSON object per row keyed by lowercased column name.

Re-exports

pub use config::SnowflakeSourceConfig;

pub use stream::SnowflakeSource;

Modules

config

Snowflake source configuration.

convert

Type-aware conversion from Snowflake SQL REST API rows to JSON objects.

stream

Snowflake SQL REST API source.

Enums

FaucetError

All possible errors returned by faucet-stream.

SnowflakeAuth

Authentication method for Snowflake.

Traits

Source

A source fetches records from an external system.