0

我需要从 Airflow 下载我公司在 Bing Ads 上的营销活动。我已经看到 Python 中有一个 Bing Ads SDK，它可能是构建自定义运算符的一个很好的起点，该运算符将对 Bing Ads 进行 API 调用，并使用 s3 挂钩将生成的 csv 上传到 S3。我之前使用 Google Ads 客户端库将广告系列下载为 PythonOperator 中的 Python 对象列表，但这个库比 BingAds 更直观。

不幸的是，Airflow 中没有 BingAds 挂钩，所以我必须完全依赖这个 Python 库并将其包装在 PythonOperator 中。过去是否有人构建了类似的解决方案，可以为我指明正确的方向？

最好的，

4

1 回答 1

1

我认为使用 PythonOperator 运行 python 代码是可以的——包括导入 Bing API——你只需要确保为调度程序和工作程序安装了包。无需为此构建自定义运算符。

您甚至可以使用任务流 API 很好地集成它https://airflow.apache.org/docs/apache-airflow/stable/tutorial_taskflow_api.html

Airlfow 旨在进行自定义扩展——因此完全可以编写 Python 代码。更多 - 如果您发现它适合您，您实际上可能会在添加所有“概括”后将其贡献回 Airflow - BingAdsProvider 会很好。

于 2021-11-27T21:37:23.003 回答