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

此條目是否對您有幫助？