说明：仅供学习使用，请勿用于非法用途，若有侵权，请联系博主删除
作者：zhu6201976
一、需求背景
App在Facebook、Google等巨头进行广告投放，想要拿到实时广告投放效果数据，如曝光、点击、花费、触达等核心指标并进行分析，可对接官方API实现。因对接过程十分复杂，此处以Facebook为例，进行简单记录。
二、对接流程
1.文档地址
https://developers.facebook.com/docs/marketing-api/insights
2. access_token获取
a. 创建App https://developers.facebook.com/apps
b. 添加产品
-
点击进入某个App --> Add products to your app --> Marketing API --> Set up
-
点击左下角Marketing API --> Tools --> 勾选token权限 --> Get Token 即可生成一个长效token，有效期2个月，过期后需要重新生成 步骤相同
c. 查看access_token有效期（可选）
复制保存步骤2生成的token，查看有效期。
地址：https://developers.facebook.com/tools/debug/accesstoken
如图所示，通过此种方式，可以获取到一个有效期2个月的长效access_token。
三、示例代码
获取到长效access_token后，我们可以开始请求广告数据了。
def __init__(self, **kwargs):super().__init__(**kwargs)self.api_url = 'https://graph.facebook.com'self.api_version = 'v19.0'1. 获取所有广告账号adaccount
def start_requests(self):page = 1url = f'{self.api_url}/{self.api_version}/me/adaccounts?'params = {'fields': 'id,name','access_token': self.access_token}url = f'{url}{urlencode(params)}'yield scrapy.Request(url, meta={'page': page}, priority=1, callback=self.parse_adaccounts)通过该API，可以获取到所有广告账号，分页返回，每页25条。fields字段控制返回的字段，此处为account_id、account_name。
后续翻页控制代码：
resp_str = resp.body.decode('utf-8', 'ignore')
resp_dict = json.loads(resp_str)
next_url = resp_dict.get('paging', {}).get('next')
if next_url:page += 1yield scrapy.Request(next_url, meta={'page': page}, priority=1, callback=self.parse_adaccounts)2. 获取广告账号广告量
为什么要获取广告账号广告量？因为如果某个广告账号下根本没有投放广告，则无需后续请求，提高效率，减少请求次数。
def get_adaccount_ads_volume_req(self, ad_account_id, ad_account_name):"""构造账号广告量查询请求https://developers.facebook.com/docs/marketing-api/insights-api/ads-volume:param ad_account_id::return:"""url = f'{self.api_url}/{self.api_version}/{ad_account_id}/ads_volume?'params = {'access_token': self.access_token}url = f'{url}{urlencode(params)}'return scrapy.Request(url,meta={'ad_account_id': ad_account_id,'ad_account_name': ad_account_name},priority=2,callback=self.parse_adaccount_ads_volume)解析账号广告量响应代码：
resp_str = resp.body.decode('utf-8', 'ignore')resp_dict = json.loads(resp_str)# self.logger.info(f'{method_name} {ad_account_id} {resp_dict}')ads_volume = resp_dict.get('data', [])self.logger.info(f'{method_name} {ad_account_id} 提取到 {len(ads_volume)} ads_volume')for volume in ads_volume:ads_running_or_in_review_count = volume.get('ads_running_or_in_review_count', 0)if ads_running_or_in_review_count > 0:yield self.get_campaigns_req(ad_account_id, ad_account_name, page=1)3. 获取广告账号所有campaign
def get_campaigns_req(self, ad_account_id, ad_account_name, page):"""构造启动campaigns请求:param ad_account_id::param ad_account_name::param page::return:"""url = f'{self.api_url}/{self.api_version}/{ad_account_id}/campaigns?'params = {'effective_status': "['ACTIVE', 'PAUSED']",'fields': 'id,name','access_token': self.access_token,}url = f'{url}{urlencode(params)}'return scrapy.Request(url,meta={'ad_account_id': ad_account_id,'ad_account_name': ad_account_name,'page': page},priority=2,callback=self.parse_get_campaigns)4. 对campaign聚合获取所有广告
该步骤非常重要，我们无需通过完整路径：adaccount --> campaign --> adset --> ads 获取到广告数据，可以利用API的level进行聚合，直接在campaign层级获取到所有广告投放数据。如下所示：
def ad_insights_req(self, ad_account_id, ad_account_name, ad_campaign_id, ad_campaign_name, d_str, page):url = f'{self.api_url}/{self.api_version}/{ad_campaign_id}/insights?'params = {'level': 'ad','fields': 'adset_id,adset_name,ad_id,ad_name,impressions,clicks,unique_clicks,spend,reach,cpc,cpm,cpp,ctr,' +'date_start,date_stop,actions,action_values',# 'date_preset': 'today', # today,yesterday,last_7d,last_30d,...'time_range': '{"since":' + f'"{d_str}"' + "," + '"until":' + f'"{d_str}"' + "}",'access_token': self.access_token,}url = f'{url}{urlencode(params)}'return scrapy.Request(url,meta={'ad_account_id': ad_account_id,'ad_account_name': ad_account_name,'ad_campaign_id': ad_campaign_id,'ad_campaign_name': ad_campaign_name,'d_str': d_str,'page': page},priority=3,callback=self.parse_ad_insights)5. 解析广告数据
for ad in ads:ad_insights_item = FbAdInsightsItem()ad_insights_item['ad_account_id'] = ad_account_idad_insights_item['ad_account_name'] = ad_account_namead_insights_item['ad_campaign_id'] = ad_campaign_idad_insights_item['ad_campaign_name'] = ad_campaign_namead_insights_item['ad_set_id'] = ad.get('adset_id', '')ad_insights_item['ad_set_name'] = ad.get('adset_name', '')ad_insights_item['ad_id'] = ad.get('ad_id', '')ad_insights_item['ad_name'] = ad.get('ad_name', '')ad_insights_item['impressions'] = ad.get('impressions', '')ad_insights_item['clicks'] = ad.get('clicks', '')ad_insights_item['unique_clicks'] = ad.get('unique_clicks', '')ad_insights_item['spend'] = ad.get('spend', '')ad_insights_item['reach'] = ad.get('reach', '')ad_insights_item['cpc'] = ad.get('cpc', '')ad_insights_item['cpm'] = ad.get('cpm', '')ad_insights_item['cpp'] = ad.get('cpp', '')ad_insights_item['ctr'] = ad.get('ctr', '')ad_insights_item['date_start'] = ad.get('date_start', '')ad_insights_item['date_stop'] = ad.get('date_stop', '')一键三连，有需要的请私聊获取详细源码。
