用于 Google BigQuery 服务本地文件上传和外部表创建的示例 Airflow DAG。
模块内容
-
tests.system.google.cloud.bigquery.example_bigquery_operations.ENV_ID[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.DAG_ID = 'bigquery_operations'[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.DATASET_NAME[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.DATA_SAMPLE_GCS_BUCKET_NAME[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.DATA_SAMPLE_GCS_OBJECT_NAME = 'bigquery/us-states/us-states.csv'[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.CSV_FILE_LOCAL_PATH[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.create_bucket[源代码]
-
tests.system.google.cloud.bigquery.example_bigquery_operations.test_run[源代码]