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)[源代码]

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

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

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

将 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。

返回

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

返回类型

Any

此条目是否有帮助？