Example Airflow DAG that shows how to use DataFusion.
Module Contents
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.SERVICE_ACCOUNT[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.PROJECT_ID[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.ENV_ID[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.DAG_ID = 'example_datafusion_async'[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.LOCATION = 'europe-north1'[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.INSTANCE_NAME[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.INSTANCE[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.BUCKET_NAME_1[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.BUCKET_NAME_2[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.BUCKET_NAME_1_URI[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.BUCKET_NAME_2_URI[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.PIPELINE_NAME[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.PIPELINE[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.create_bucket1[source]
-
tests.system.providers.google.cloud.datafusion.example_datafusion_async.test_run[source]
