Example Airflow DAG that shows how to use Dataplex Scan Data.
Module Contents
-
tests.system.google.cloud.dataplex.example_dataplex_dp.ENV_ID[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.PROJECT_ID[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.DAG_ID = 'dataplex_data_profile'[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.LAKE_ID[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.REGION = 'us-central1'[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.DATASET[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.TABLE_1 = 'table0'[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.TABLE_2 = 'table1'[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.SCHEMA[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.INSERT_DATE[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.INSERT_ROWS_QUERY[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.LOCATION = 'us'[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.TRIGGER_SPEC_TYPE = 'ON_DEMAND'[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.ZONE_ID[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.DATA_SCAN_ID[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.EXAMPLE_LAKE_BODY[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.EXAMPLE_ZONE[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.ASSET_ID[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.EXAMPLE_ASSET[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.EXAMPLE_DATA_SCAN[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.UPDATE_MASK[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.ENTITY[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.EXAMPLE_DATA_SCAN_UPDATE[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.create_dataset[source]
-
tests.system.google.cloud.dataplex.example_dataplex_dp.test_run[source]