tests.system.google.cloud.bigquery.example_bigquery_queries_async¶

Example Airflow DAG for Google BigQuery service. Uses Async version of the Big Query Operators

Attributes¶

`ENV_ID`
`PROJECT_ID`
`DAG_ID`
`DATASET_NAME`
`LOCATION`
`TABLE_NAME_1`
`TABLE_NAME_2`
`SCHEMA`
`INSERT_DATE`
`INSERT_ROWS_QUERY`
`CONFIGURATION`
`default_args`
`create_dataset`
`test_run`

Module Contents¶

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

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

tests.system.google.cloud.bigquery.example_bigquery_queries_async.DAG_ID = 'bigquery_queries_async'[source]¶

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

tests.system.google.cloud.bigquery.example_bigquery_queries_async.LOCATION = 'us'[source]¶

tests.system.google.cloud.bigquery.example_bigquery_queries_async.TABLE_NAME_1 = ''[source]¶

tests.system.google.cloud.bigquery.example_bigquery_queries_async.TABLE_NAME_2 = ''[source]¶

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

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

tests.system.google.cloud.bigquery.example_bigquery_queries_async.INSERT_ROWS_QUERY[source]¶

tests.system.google.cloud.bigquery.example_bigquery_queries_async.CONFIGURATION[source]¶

tests.system.google.cloud.bigquery.example_bigquery_queries_async.default_args[source]¶

tests.system.google.cloud.bigquery.example_bigquery_queries_async.create_dataset[source]¶

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

Was this entry helpful?