tests.system.google.cloud.bigquery.example_bigquery_routines

Example Airflow DAG for Google BigQuery service testing routine operations.

Exercises the full BigQuery routines lifecycle through Airflow: create a scalar SQL UDF, a stored procedure, and a table-valued function; verify their existence; list and fetch them; update one; and delete them all.

Attributes

ENV_ID

PROJECT_ID

DAG_ID

DATASET_NAME

SCALAR_ROUTINE

PROCEDURE_ROUTINE

TVF_ROUTINE

INT64_TYPE

STRING_TYPE

create_dataset

test_run

Module Contents

tests.system.google.cloud.bigquery.example_bigquery_routines.ENV_ID[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.PROJECT_ID[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.DAG_ID = 'bigquery_routines'[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.DATASET_NAME[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.SCALAR_ROUTINE[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.PROCEDURE_ROUTINE[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.TVF_ROUTINE[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.INT64_TYPE[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.STRING_TYPE[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.create_dataset[source]
tests.system.google.cloud.bigquery.example_bigquery_routines.test_run[source]

Was this entry helpful?