airflow.providers.google.cloud.utils.bigquery

Module Contents

Functions

bq_cast(string_field, bq_type)

Helper method that casts a BigQuery row to the appropriate data types.

convert_job_id(job_id, project_id, location)

Helper method that converts to path: project_id:location:job_id

airflow.providers.google.cloud.utils.bigquery.bq_cast(string_field, bq_type)[source]

Helper method that casts a BigQuery row to the appropriate data types. This is useful because BigQuery returns all fields as strings.

airflow.providers.google.cloud.utils.bigquery.convert_job_id(job_id, project_id, location)[source]

Helper method that converts to path: project_id:location:job_id :param project_id: Required. The ID of the Google Cloud project where workspace located. :param location: Optional. The ID of the Google Cloud region where workspace located. :param job_id: Required. The ID of the job. :return: str or list[str] of project_id:location:job_id.

Was this entry helpful?