astro.databases

Subpackages

• astro.databases.aws
  • astro.databases.aws.redshift
• astro.databases.databricks
  • astro.databases.databricks.load_file
    • astro.databases.databricks.load_file.load_file_job
    • astro.databases.databricks.load_file.load_file_python_code_generator
  • astro.databases.databricks.api_utils
  • astro.databases.databricks.delta
  • astro.databases.databricks.load_options
• astro.databases.google
  • astro.databases.google.bigquery

Submodules

• astro.databases.base
• astro.databases.duckdb
• astro.databases.mssql
• astro.databases.mysql
• astro.databases.postgres
• astro.databases.snowflake
• astro.databases.sqlite

Package Contents

Functions

create_database(conn_id[, table, load_options_list])

Given a conn_id, return the associated Database class.

Attributes

DEFAULT_CONN_TYPE_TO_MODULE_PATH
CUSTOM_CONN_TYPE_TO_MODULE_PATH
CONN_TYPE_TO_MODULE_PATH
SUPPORTED_DATABASES

astro.databases.DEFAULT_CONN_TYPE_TO_MODULE_PATH

astro.databases.CUSTOM_CONN_TYPE_TO_MODULE_PATH

astro.databases.CONN_TYPE_TO_MODULE_PATH

astro.databases.SUPPORTED_DATABASES

astro.databases.create_database(conn_id, table=None, load_options_list=None)

Given a conn_id, return the associated Database class.

Parameters:

• conn_id (str) – Database connection ID in Airflow

• table (astro.table.BaseTable | None) – (optional) The Table object

• load_options_list (astro.options.LoadOptionsList | None) –

Return type:

base.BaseDatabase