feast.infra.utils.postgres package¶
Submodules¶
feast.infra.utils.postgres.connection_utils module¶
- feast.infra.utils.postgres.connection_utils.df_to_postgres_table(config: feast.infra.utils.postgres.postgres_config.PostgreSQLConfig, df: pandas.core.frame.DataFrame, table_name: str) Dict[str, numpy.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: feast.infra.utils.postgres.postgres_config.PostgreSQLConfig, sql_query: str) Dict[str, numpy.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.PostgreSQLConfig(*, host: pydantic.types.StrictStr, port: int = 5432, database: pydantic.types.StrictStr, db_schema: pydantic.types.StrictStr = 'public', user: pydantic.types.StrictStr, password: pydantic.types.StrictStr, sslmode: Optional[pydantic.types.StrictStr] = None, sslkey_path: Optional[pydantic.types.StrictStr] = None, sslcert_path: Optional[pydantic.types.StrictStr] = None, sslrootcert_path: Optional[pydantic.types.StrictStr] = None)[source]¶
Bases:
feast.repo_config.FeastConfigBaseModel
- database: pydantic.types.StrictStr¶
- db_schema: pydantic.types.StrictStr¶
- host: pydantic.types.StrictStr¶
- password: pydantic.types.StrictStr¶
- sslcert_path: Optional[pydantic.types.StrictStr]¶
- sslkey_path: Optional[pydantic.types.StrictStr]¶
- sslmode: Optional[pydantic.types.StrictStr]¶
- sslrootcert_path: Optional[pydantic.types.StrictStr]¶
- user: pydantic.types.StrictStr¶