用于 Google Cloud Dataflow 服务的示例 Airflow DAG
模块内容
-
tests.system.google.cloud.dataflow.example_dataflow_sql.PROJECT_ID[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.ENV_ID[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.DAG_ID = 'dataflow_sql'[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.LOCATION = 'europe-west3'[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.DATAFLOW_SQL_JOB_NAME[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_DATASET[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_TABLE_INPUT[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_TABLE_OUTPUT[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.INSERT_ROWS_QUERY[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.create_bq_dataset[源代码]
-
tests.system.google.cloud.dataflow.example_dataflow_sql.test_run[源代码]