Google Ads 操作符¶

Google Ads（前称 Google AdWords 和 Google AdWords Express），是一个平台，允许企业在 Google 搜索、YouTube 以及网络上的其他站点进行广告投放。

前置任务¶

要使用这些操作符，您需要完成以下几项工作

使用云控制台选择或创建一个云平台项目。

为您的项目启用计费，方法请参阅 Google Cloud 文档。

启用 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[source]

run_operator = GoogleAdsToGcsOperator(
    client_ids=[get_google_ads_client_id_task],
    query=QUERY,
    attributes=FIELDS_TO_EXTRACT,
    obj=GCS_OBJ_PATH,
    bucket=BUCKET_NAME,
    task_id="run_operator",
    api_version=API_VERSION,
    gcp_conn_id=CONNECTION_GLOUD_ID,
)

使用 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[source]

list_accounts = GoogleAdsListAccountsOperator(
    task_id="list_accounts",
    bucket=BUCKET_NAME,
    object_name=GCS_ACCOUNTS_CSV,
    api_version=API_VERSION,
    gcp_conn_id=CONNECTION_GLOUD_ID,
)

使用 Jinja 模板，并使用这些参数来动态确定值

bucket
object_name
impersonation_chain

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