示例 Airflow DAG，展示如何使用 DataFusion。
模块内容
-
tests.system.google.cloud.datafusion.example_datafusion.SERVICE_ACCOUNT[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.PROJECT_ID[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.ENV_ID[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.LOCATION = 'europe-north1'[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.DAG_ID = 'datafusion'[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.INSTANCE_NAME[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.INSTANCE[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.BUCKET_NAME_1[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.BUCKET_NAME_2[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.BUCKET_NAME_1_URI[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.BUCKET_NAME_2_URI[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.PIPELINE_NAME[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.PIPELINE[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.create_bucket1[源代码]
-
tests.system.google.cloud.datafusion.example_datafusion.test_run[源代码]