tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam¶

Example Airflow DAG that performs query in a Cloud SQL instance with IAM service account authentication.

Functions¶

`ip_configuration`()	Generates an ip configuration for a CloudSQL instance creation body
`cloud_sql_instance_create_body`(database_provider)	Generates a CloudSQL instance creation body
`cloud_sql_database_create_body`(instance)	Generates a CloudSQL database creation body

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.ENV_ID[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.PROJECT_ID[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.DAG_ID = 'cloudsql_query_iam'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.REGION = 'us-central1'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.HOME_DIR[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.IS_COMPOSER[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_INSTANCE_NAME_TEMPLATE = ''[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_INSTANCE_CREATE_BODY_TEMPLATE: dict[str, Any][source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.ip_configuration()[source]¶

Generates an ip configuration for a CloudSQL instance creation body

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.cloud_sql_instance_create_body(database_provider)[source]¶

Generates a CloudSQL instance creation body

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_DATABASE_NAME = 'test_db'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_USER = 'test_user'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_IAM_SA[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_IP_ADDRESS = '127.0.0.1'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_PUBLIC_PORT = 5432[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.DB_PROVIDERS: collections.abc.Iterable[dict[str, str]][source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.cloud_sql_database_create_body(instance)[source]¶

Generates a CloudSQL database creation body

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CLOUD_SQL_INSTANCE_NAME = ''[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.DATABASE_TYPE = ''[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CONNECTION_WITH_IAM_KWARGS[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.CONNECTION_PUBLIC_TCP_SSL_ID = 'cloudsql_query_iam_Uninferable_tcp_ssl'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.PG_SQL = ['SELECT * FROM pg_catalog.pg_tables'][source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.MYSQL_SQL = ['SHOW TABLES'][source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.SSL_PATH = '/cloudsql_query_iam/Uninferable'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.SSL_LOCAL_PATH_PREFIX = '/tmp'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.SSL_COMPOSER_PATH_PREFIX = '/home/airflow/gcs/data'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.postgres_kwargs[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.mysql_kwargs[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.log[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.database_type: str = 'postgres'[source]¶

tests.system.google.cloud.cloud_sql.example_cloud_sql_query_iam.test_run[source]¶

`ENV_ID`
`PROJECT_ID`
`DAG_ID`
`REGION`
`HOME_DIR`
`IS_COMPOSER`
`CLOUD_SQL_INSTANCE_NAME_TEMPLATE`
`CLOUD_SQL_INSTANCE_CREATE_BODY_TEMPLATE`
`CLOUD_SQL_DATABASE_NAME`
`CLOUD_SQL_USER`
`CLOUD_IAM_SA`
`CLOUD_SQL_IP_ADDRESS`
`CLOUD_SQL_PUBLIC_PORT`
`DB_PROVIDERS`
`CLOUD_SQL_INSTANCE_NAME`
`DATABASE_TYPE`
`CONNECTION_WITH_IAM_KWARGS`
`CONNECTION_PUBLIC_TCP_SSL_ID`
`PG_SQL`
`MYSQL_SQL`
`SSL_PATH`
`SSL_LOCAL_PATH_PREFIX`
`SSL_COMPOSER_PATH_PREFIX`
`postgres_kwargs`
`mysql_kwargs`
`log`
`database_type`
`test_run`