Skip to main content

micromegas_ingestion/
data_lake_config.rs

1use anyhow::{Context, Result};
2
3/// The two env vars every lake-backed role needs.
4#[derive(Debug, Clone)]
5pub struct DataLakeConfig {
6    pub sql_connection_string: String,
7    pub object_store_uri: String,
8}
9
10impl DataLakeConfig {
11    pub fn from_env() -> Result<Self> {
12        Ok(Self {
13            sql_connection_string: std::env::var("MICROMEGAS_SQL_CONNECTION_STRING")
14                .context("reading MICROMEGAS_SQL_CONNECTION_STRING")?,
15            object_store_uri: std::env::var("MICROMEGAS_OBJECT_STORE_URI")
16                .context("reading MICROMEGAS_OBJECT_STORE_URI")?,
17        })
18    }
19}