Google Ads 操作符¶

Google Ads，前身为 Google AdWords 和 Google AdWords Express，是一个允许企业在 Google 搜索、YouTube 和网络其他网站上投放广告的平台。

先决条件任务¶

要使用这些操作符，您必须执行以下几项操作：

使用 Cloud Console 选择或创建一个 Cloud Platform 项目。

按照 Google Cloud 文档中的说明，为您的项目启用结算功能。

按照 Cloud Console 文档中的说明启用 API。
通过 pip 安装 API 库。
pip install 'apache-airflow[google]'
安装提供了详细信息。
设置 Google Cloud 连接.

Google Ads 到 GCS¶

要查询 Google Ads API 并生成结果的 CSV 报告，请使用 GoogleAdsToGcsOperator。

tests/system/google/ads/example_ads.py[源代码]

run_operator = GoogleAdsToGcsOperator(
    client_ids=CLIENT_IDS,
    query=QUERY,
    attributes=FIELDS_TO_EXTRACT,
    obj=GCS_OBJ_PATH,
    bucket=BUCKET_NAME,
    task_id="run_operator",
)

将 Jinja 模板与那些允许您动态确定值的参数一起使用

client_ids
query
attributes
bucket
obj
impersonation_chain

结果会保存到 XCom，这允许其他操作符使用该结果。

将 Google Ads 帐户上传到 GCS¶

要将 Google Ads 帐户上传到 Google Cloud Storage 存储桶，请使用 GoogleAdsListAccountsOperator。

tests/system/google/ads/example_ads.py[源代码]

list_accounts = GoogleAdsListAccountsOperator(
    task_id="list_accounts", bucket=BUCKET_NAME, object_name=GCS_ACCOUNTS_CSV
)

将 Jinja 模板与那些允许您动态确定值的参数一起使用

bucket
object_name
impersonation_chain

允许您动态确定值的参数。结果会保存到 XCom，这允许其他操作符使用该结果。