`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 to GCS

参数

client_ids (list[str]) – 要查询的 Google Ads 客户 ID
query (str) – Google Ads 查询语言 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。

airflow.providers.google.ads.transfers.ads_to_gcs¶

模块内容¶

类¶

`airflow.providers.google.ads.transfers.ads_to_gcs`¶