airflow.providers.google.ads.transfers.ads_to_gcs

模組內容

類別

GoogleAdsToGcsOperator

從 Google Ads API 為 1-n 個客戶端提取每日結果。

class airflow.providers.google.ads.transfers.ads_to_gcs.GoogleAdsToGcsOperator(*, client_ids, query, attributes, bucket, obj, gcp_conn_id='google_cloud_default', google_ads_conn_id='google_ads_default', page_size=10000, gzip=False, impersonation_chain=None, api_version=None, **kwargs)[來源]

基類: airflow.models.BaseOperator

從 Google Ads API 為 1-n 個客戶端提取每日結果。

轉換資料並儲存為暫時的 CSV 檔案,然後上傳 CSV 檔案到 Google Cloud Storage。

另請參閱

有關 Google Ads API 的更多資訊,請參閱 API 文件: https://developers.google.com/google-ads/api/docs/start

另請參閱

有關如何使用此運算子的更多資訊,請參閱指南: Google Ads 到 GCS

參數
  • client_ids (list[str]) – 要查詢的 Google Ads 客戶端 ID

  • query (str) – Google Ads Query Language API 查詢

  • attributes (list[str]) – 要提取的 Google Ads 列屬性列表

  • bucket (str) – 要上傳到的 GCS 儲存桶

  • obj (str) – 儲存物件的 GCS 路徑。必須是完整檔案路徑 (例如:path/to/file.txt)

  • gcp_conn_id (str) – Airflow Google Cloud 連線 ID

  • google_ads_conn_id (str) – Airflow Google Ads 連線 ID

  • page_size (int) – 每個 API 頁面請求的結果數量。最大值為 10,000

  • gzip (bool) – 壓縮本機檔案或檔案資料以上傳的選項

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 使用短期憑證模擬的可選服務帳戶,或是取得列表中最後一個帳戶的 access_token 所需的帳戶鏈式列表,該帳戶將在請求中被模擬。如果設定為字串,則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列,則列表中的身分必須授予緊接在前的身分「服務帳戶權杖建立者」IAM 角色,列表中的第一個帳戶將此角色授予原始帳戶 (已範本化)。

  • api_version (str | None) – 要使用的可選 Google Ads API 版本。

template_fields: collections.abc.Sequence[str] = ('client_ids', 'query', 'attributes', 'bucket', 'obj', 'impersonation_chain')[來源]
execute(context)[來源]

在建立運算子時衍生。

上下文與呈現 Jinja 範本時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

此條目是否有幫助?