feast.infra.utils.postgres package


feast.infra.utils.postgres.connection_utils module

feast.infra.utils.postgres.connection_utils.df_to_postgres_table(config: PostgreSQLConfig, df: DataFrame, table_name: str) Dict[str, dtype][source]

Create a table for the data frame, insert all the values, and return the table schema

feast.infra.utils.postgres.connection_utils.get_query_schema(config: PostgreSQLConfig, sql_query: str) Dict[str, dtype][source]

We’ll use the statement when we perform the query rather than copying data to a new table

feast.infra.utils.postgres.postgres_config module

class feast.infra.utils.postgres.postgres_config.ConnectionType(value)[source]

Bases: Enum

An enumeration.

pool = 'pool'
singleton = 'singleton'
class feast.infra.utils.postgres.postgres_config.PostgreSQLConfig(*, min_conn: int = 1, max_conn: int = 10, conn_type: ConnectionType = ConnectionType.singleton, host: StrictStr, port: int = 5432, database: StrictStr, db_schema: StrictStr = 'public', user: StrictStr, password: StrictStr, sslmode: StrictStr | None = None, sslkey_path: StrictStr | None = None, sslcert_path: StrictStr | None = None, sslrootcert_path: StrictStr | None = None, keepalives_idle: int | None = None)[source]

Bases: FeastConfigBaseModel

conn_type: ConnectionType
database: StrictStr
db_schema: StrictStr
host: StrictStr
keepalives_idle: int | None
max_conn: int
min_conn: int
password: StrictStr
port: int
sslcert_path: StrictStr | None
sslkey_path: StrictStr | None
sslmode: StrictStr | None
sslrootcert_path: StrictStr | None
user: StrictStr

Module contents