Google Ads Operator¶
Google Ads,前身为 Google AdWords 和 Google AdWords Express,是一个允许企业在 Google 搜索、YouTube 以及网络上其他网站投放广告的平台。
前置任务¶
要使用这些 Operator,您必须完成以下几项操作:
使用 Cloud Console 选择或创建一个 Cloud Platform 项目。
为您的项目启用计费功能,具体参见 Google Cloud 文档 中的说明。
启用 API,具体参见 Cloud Console 文档 中的说明。
通过 pip 安装 API 库。
pip install 'apache-airflow[google]'详细信息请参阅 安装。
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",
api_version=API_VERSION,
)
对允许您动态确定值的参数使用 Jinja 模板化:
client_ids
query
attributes
bucket
obj
impersonation_chain
结果被保存到 XCom,这使得结果可以被其他 Operator 使用。
将 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,这使得结果可以被其他 Operator 使用。