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

此條目有幫助嗎？