PostgresSource
class PostgresSource(
uri: str,
query: str | List[str],
credentials: dict | UserPasswordCredentials | None = None,
initial_values: dict | None = None,
)
Bases: Input
Categories: source
Class for managing the configuration of Postgres-based data inputs.
Attributes: credentials (UserPasswordCredentials): The credentials required to access the Postgres database. initial_values (dict): The initial values for the parameters in the SQL queries. query (str | List[str]): The SQL query(s) to execute. If multiple queries are provided, they must be provided as a dictionary, with the parameter name in the registered function as the key and the SQL query as the value. uri (str): The URI of the database where the data is located.
Methods: to_dict(): Converts the PostgresSource object to a dictionary.
Initializes the PostgresSource with the given URI and query, and optionally connection credentials and initial values for the parameters in the SQL queries.
Parameters
uristrThe URI of the database where the data is located
querystr | List[str]The SQL query(s) to execute. If multiple queries are provided, they must be provided as a list, and they will be mapped to the function inputs in the same order as they are defined.
credentialsdict | UserPasswordCredentials, optionalThe credentials required to access the Postgres database. Can be a dictionary or a UserPasswordCredentials object.
initial_valuesdict, optionalThe initial values for the parameters in the SQL queries.
Raises
InputConfigurationError
Properties
credentialsUserPasswordCredentials | NoneThe credentials required to access the PostgresDatabase. If no credentials were provided, it will return None.
initial_valuesdictThe initial values for the parameters in the SQL queries.
querystr | List[str]The SQL query(s) to execute.
uristrThe URI of the database where the data is located.
Methods
to_dictdef to_dict() -> dict
Converts the PostgresSource object to a dictionary with all the relevant information.
Returns:
dict: A dictionary with the relevant information of the PostgresSource object.