Example Airflow DAG for Google Cloud Dataflow service
Module Contents
-
tests.system.google.cloud.dataflow.example_dataflow_sql.PROJECT_ID[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.ENV_ID[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.DAG_ID = 'dataflow_sql'[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.LOCATION = 'europe-west3'[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.DATAFLOW_SQL_JOB_NAME[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_DATASET[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_TABLE_INPUT[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_TABLE_OUTPUT[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.INSERT_ROWS_QUERY[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.create_bq_dataset[source]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.test_run[source]