airflow.providers.google.cloud.utils.bigquery

函数

bq_cast(string_field, bq_type)

将 BigQuery 行转换为适当的数据类型。

convert_job_id(job_id, project_id, location)

将 job_id 转换为路径: project_id:location:job_id。

模块内容

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

将 BigQuery 行转换为适当的数据类型。

这很有用，因为 BigQuery 将所有字段作为字符串返回。

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

将 job_id 转换为路径: project_id:location:job_id。

参数:

  • project_id (str) – 必需。工作区所在的 Google Cloud 项目 ID。

  • location (str | None) – 可选。工作区所在的 Google Cloud 区域 ID。

  • job_id (str | list[str]) – 必需。作业 ID。

返回:

str 或 list[str] 类型的 project_id:location:job_id。

返回类型:

Any

此条目有帮助吗？