tests.system.google.cloud.cloud_sql.example_cloud_sql_query

Example Airflow DAG that performs query in a Cloud SQL instance.

Attributes

ENV_ID

PROJECT_ID

DAG_ID

REGION

HOME_DIR

COMPOSER_ENVIRONMENT

CLOUD_SQL_INSTANCE_NAME_TEMPLATE

CLOUD_SQL_INSTANCE_CREATE_BODY_TEMPLATE

DB_PROVIDERS

CLOUD_SQL_DATABASE_NAME

CLOUD_SQL_USER

CLOUD_SQL_PASSWORD

CLOUD_SQL_IP_ADDRESS

CLOUD_SQL_PUBLIC_PORT

CLOUD_SQL_INSTANCE_NAME

DATABASE_TYPE

CONNECTION_PROXY_TCP_KWARGS

CONNECTION_PROXY_SOCKET_KWARGS

CONNECTION_PUBLIC_TCP_KWARGS

CONNECTION_PROXY_SOCKET_ID

CONNECTION_PROXY_TCP_ID

CONNECTION_PUBLIC_TCP_ID

CONNECTIONS

SQL

postgres_kwargs

mysql_kwargs

log

check_openlineage_events

test_run

Classes

ConnectionConfig

Functions

run_in_composer()

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

Module Contents

tests.system.google.cloud.cloud_sql.example_cloud_sql_query.ENV_ID[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.PROJECT_ID[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.DAG_ID = 'cloudsql_query'[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.REGION = 'us-central1'[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.HOME_DIR[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.COMPOSER_ENVIRONMENT[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.run_in_composer()[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_INSTANCE_NAME_TEMPLATE[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_INSTANCE_CREATE_BODY_TEMPLATE: dict[str, Any][source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.DB_PROVIDERS: collections.abc.Iterable[dict[str, str]][source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.ip_configuration()[source]

Generates an ip configuration for a CloudSQL instance creation body

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

Generates a CloudSQL instance creation body

tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_DATABASE_NAME = 'test_db'[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_USER = 'test_user'[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_PASSWORD = 'JoxHlwrPzwch0gz9'[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_IP_ADDRESS = '127.0.0.1'[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_PUBLIC_PORT = 5432[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.cloud_sql_database_create_body(instance)[source]

Generates a CloudSQL database creation body

tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CLOUD_SQL_INSTANCE_NAME = ''[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.DATABASE_TYPE = ''[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTION_PROXY_TCP_KWARGS[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTION_PROXY_SOCKET_KWARGS[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTION_PUBLIC_TCP_KWARGS[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTION_PROXY_SOCKET_ID[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTION_PROXY_TCP_ID[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTION_PUBLIC_TCP_ID[source]
class tests.system.google.cloud.cloud_sql.example_cloud_sql_query.ConnectionConfig[source]

Bases: tuple

id[source]
kwargs[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.CONNECTIONS[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.SQL = ['CREATE TABLE IF NOT EXISTS TABLE_TEST (I INTEGER)', 'CREATE TABLE IF NOT EXISTS TABLE_TEST (I...[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.postgres_kwargs[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.mysql_kwargs[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.log[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.check_openlineage_events[source]
tests.system.google.cloud.cloud_sql.example_cloud_sql_query.test_run[source]

Was this entry helpful?