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', 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

另请参阅

有关如何使用此 Operator 的更多信息,请查阅指南:Google Ads to GCS

参数
  • client_ids (list[str]) – 要查询的 Google Ads 客户端 ID 列表

  • query (str) – Google Ads Query Language API 查询语句

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

  • bucket (str) – 要上传到的 GCS bucket 名称

  • obj (str) – 保存对象的 GCS 路径。必须是完整的文件路径(例如 path/to/file.txt

  • gcp_conn_id (str) – Airflow Google Cloud 连接 ID

  • google_ads_conn_id (str) – Airflow Google Ads 连接 ID

  • gzip (bool) – 用于压缩本地文件或文件数据以便上传的选项

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐号,用于使用短期凭证进行模拟,或者所需帐号的链式列表,以获取列表中最后一个帐号的 access_token,该帐号将在请求中被模拟。如果设置为字符串,则该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列,则列表中的身份必须授予 Service Account Token Creator IAM 角色给直接在其之前的身份,列表中的第一个帐号将此角色授予发起帐号(模板化)。

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

template_fields: collections.abc.Sequence[str] = ('client_ids', 'query', 'attributes', 'bucket', 'obj', 'impersonation_chain')[源码]
client_ids[源码]
query[源码]
attributes[源码]
bucket[源码]
obj[源码]
gcp_conn_id = 'google_cloud_default'[源码]
google_ads_conn_id = 'google_ads_default'[源码]
gzip = False[源码]
impersonation_chain = None[源码]
api_version = None[源码]
execute(context)[源码]

创建 operator 时进行派生。

上下文与用于渲染 Jinja 模板的字典相同。

更多上下文信息请参阅 get_template_context。

此条目有帮助吗?