tests.system.google.cloud.bigquery.example_bigquery_jobs¶

Example Airflow DAG for Google BigQuery service.

Attributes¶

`ENV_ID`
`PROJECT_ID`
`LOCATION`
`TABLE_1`
`TABLE_2`
`TABLE_3`
`TABLE_4`
`SCHEMA`
`DAG_ID`
`DATASET_NAME`
`BUCKET_NAME`
`DATASET`
`INSERT_DATE`
`INSERT_ROWS_QUERY`
`CTAS_QUERY`
`create_bucket`
`test_run`

Module Contents¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.ENV_ID[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.PROJECT_ID[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.LOCATION = 'us-east1'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.TABLE_1 = 'table1'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.TABLE_2 = 'table2'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.TABLE_3 = 'table3'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.TABLE_4 = 'table4'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.SCHEMA[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.DAG_ID = 'bigquery_jobs'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.DATASET_NAME = 'dataset_bigquery_jobs_Uninferable'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.BUCKET_NAME = 'bucket_bigquery_jobs_Uninferable'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.DATASET = 'dataset_bigquery_jobs_Uninferable1'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.INSERT_DATE = '2030-01-01'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.INSERT_ROWS_QUERY = "INSERT dataset_bigquery_jobs_Uninferable1.table1 VALUES (42, 'monty python', '2030-01-01'),...[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.CTAS_QUERY = 'CREATE OR REPLACE TABLE dataset_bigquery_jobs_Uninferable1.table3 AS SELECT value, name, ds...[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.create_bucket[source]¶

tests.system.google.cloud.bigquery.example_bigquery_jobs.test_run[source]¶

Was this entry helpful?