airflow.providers.google.cloud.utils.bigquery

Functions

bq_cast(string_field, bq_type)

Cast a BigQuery row to the appropriate data types.

convert_job_id(job_id, project_id, location)

Convert job_id to path: project_id:location:job_id.

Module Contents

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

Cast 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]

Convert job_id to path: project_id:location:job_id.

Parameters:

  • project_id (str) – Required. The ID of the Google Cloud project where workspace located.

  • location (str | None) – Optional. The ID of the Google Cloud region where workspace located.

  • job_id (str | list[str]) – Required. The ID of the job.

Returns:

str or list[str] of project_id:location:job_id.

Return type:

Any

Was this entry helpful?