How to Integrate Replit with Facebook Ads

1import os
2import time
3from facebook_business.api import FacebookAdsApi
4from facebook_business.adobjects.adaccount import AdAccount
5from facebook_business.adobjects.campaign import Campaign
6from facebook_business.adobjects.adset import AdSet
7
8# Initialize the Facebook Ads API
9access_token = os.environ["FACEBOOK_ACCESS_TOKEN"]
10app_id = os.environ["FACEBOOK_APP_ID"]
11app_secret = os.environ["FACEBOOK_APP_SECRET"]
12ad_account_id = os.environ["FACEBOOK_AD_ACCOUNT_ID"]  # e.g., 'act_123456789'
13
14FacebookAdsApi.init(app_id, app_secret, access_token)
15my_account = AdAccount(ad_account_id)
16
17def get_campaigns(status: list = None) -> list:
18    """
19    Fetch campaigns from the ad account.
20    status: list of statuses to filter, e.g., ['ACTIVE', 'PAUSED']
21    """
22    fields = [
23        Campaign.Field.id,
24        Campaign.Field.name,
25        Campaign.Field.status,
26        Campaign.Field.objective,
27        Campaign.Field.daily_budget,
28        Campaign.Field.lifetime_budget,
29    ]
30    params = {}
31    if status:
32        params['effective_status'] = status
33
34    campaigns = my_account.get_campaigns(fields=fields, params=params)
35    return [dict(c) for c in campaigns]
36
37def get_campaign_insights(campaign_id: str, date_preset: str = 'last_7d') -> dict:
38    """
39    Get performance insights for a campaign.
40    date_preset options: 'today', 'yesterday', 'last_7d', 'last_30d', 'this_month'
41    """
42    campaign = Campaign(campaign_id)
43    fields = ['spend', 'impressions', 'clicks', 'ctr', 'cpm', 'reach', 'actions']
44    params = {
45        'date_preset': date_preset,
46        'level': 'campaign'
47    }
48    insights = campaign.get_insights(fields=fields, params=params)
49    return dict(insights[0]) if insights else {}
50
51def get_all_campaign_insights(date_preset: str = 'last_7d') -> list:
52    """
53    Fetch insights for all active campaigns with rate limit handling.
54    """
55    campaigns = get_campaigns(status=['ACTIVE'])
56    results = []
57    for campaign in campaigns:
58        try:
59            insights = get_campaign_insights(campaign['id'], date_preset)
60            results.append({
61                'campaign_id': campaign['id'],
62                'campaign_name': campaign['name'],
63                'spend': insights.get('spend', '0'),
64                'impressions': insights.get('impressions', '0'),
65                'clicks': insights.get('clicks', '0'),
66                'ctr': insights.get('ctr', '0'),
67            })
68            time.sleep(0.1)  # Respect rate limits
69        except Exception as e:
70            print(f"Error fetching insights for {campaign['name']}: {e}")
71    return results
72
73def pause_campaign(campaign_id: str) -> bool:
74    """Pause an active campaign."""
75    campaign = Campaign(campaign_id)
76    campaign.api_update(params={'status': Campaign.Status.paused})
77    print(f"Campaign {campaign_id} paused")
78    return True
79
80# Example usage
81if __name__ == "__main__":
82    print("Fetching active campaigns...")
83    campaigns = get_campaigns(status=['ACTIVE'])
84    print(f"Found {len(campaigns)} active campaigns")
85    for c in campaigns[:3]:
86        print(f"  [{c['id']}] {c['name']} — {c['status']}")
87
88    print("\nFetching insights for last 7 days...")
89    insights = get_all_campaign_insights('last_7d')
90    for i in insights[:3]:
91        print(f"  {i['campaign_name']}: ${i['spend']} spend, {i['clicks']} clicks")

1const express = require('express');
2const { FacebookAdsApi, AdAccount, Campaign } = require('facebook-nodejs-business-sdk');
3
4const app = express();
5app.use(express.json());
6
7const ACCESS_TOKEN = process.env.FACEBOOK_ACCESS_TOKEN;
8const APP_ID = process.env.FACEBOOK_APP_ID;
9const APP_SECRET = process.env.FACEBOOK_APP_SECRET;
10const AD_ACCOUNT_ID = process.env.FACEBOOK_AD_ACCOUNT_ID; // 'act_XXXXXXXXX'
11
12// Initialize the API
13const api = FacebookAdsApi.init(ACCESS_TOKEN);
14const account = new AdAccount(AD_ACCOUNT_ID);
15
16// Get all campaigns with their status
17app.get('/campaigns', async (req, res) => {
18  try {
19    const campaigns = await account.getCampaigns(
20      ['id', 'name', 'status', 'objective', 'daily_budget'],
21      { effective_status: req.query.status ? [req.query.status] : ['ACTIVE', 'PAUSED'] }
22    );
23    res.json(campaigns.map(c => c._data));
24  } catch (err) {
25    console.error('Campaigns error:', err);
26    res.status(500).json({ error: err.message });
27  }
28});
29
30// Get insights for a specific campaign
31app.get('/campaigns/:id/insights', async (req, res) => {
32  try {
33    const campaign = new Campaign(req.params.id);
34    const insights = await campaign.getInsights(
35      ['spend', 'impressions', 'clicks', 'ctr', 'cpm', 'actions'],
36      { date_preset: req.query.period || 'last_7d', level: 'campaign' }
37    );
38    res.json(insights.length > 0 ? insights[0]._data : { message: 'No data for this period' });
39  } catch (err) {
40    res.status(500).json({ error: err.message });
41  }
42});
43
44// Get account-level spend summary
45app.get('/account/insights', async (req, res) => {
46  try {
47    const insights = await account.getInsights(
48      ['spend', 'impressions', 'clicks', 'reach'],
49      { date_preset: req.query.period || 'last_30d' }
50    );
51    res.json(insights.length > 0 ? insights[0]._data : { spend: '0' });
52  } catch (err) {
53    res.status(500).json({ error: err.message });
54  }
55});
56
57// Create a campaign (starts in PAUSED status for safety)
58app.post('/campaigns', async (req, res) => {
59  const { name, objective, daily_budget } = req.body;
60  if (!name || !objective) {
61    return res.status(400).json({ error: 'name and objective are required' });
62  }
63  try {
64    const campaign = await account.createCampaign(
65      [],
66      {
67        [Campaign.Fields.name]: name,
68        [Campaign.Fields.objective]: objective,  // e.g., 'LINK_CLICKS', 'CONVERSIONS'
69        [Campaign.Fields.status]: Campaign.Status.paused,
70        [Campaign.Fields.special_ad_categories]: [],
71        ...(daily_budget ? { [Campaign.Fields.daily_budget]: daily_budget } : {})
72      }
73    );
74    res.status(201).json({ id: campaign.id, name });
75  } catch (err) {
76    console.error('Create campaign error:', err.response?.data);
77    res.status(500).json({ error: err.message });
78  }
79});
80
81// Pause or resume a campaign
82app.patch('/campaigns/:id/status', async (req, res) => {
83  const { status } = req.body;  // 'ACTIVE' or 'PAUSED'
84  if (!['ACTIVE', 'PAUSED'].includes(status)) {
85    return res.status(400).json({ error: 'status must be ACTIVE or PAUSED' });
86  }
87  try {
88    const campaign = new Campaign(req.params.id);
89    await campaign.update([Campaign.Fields.status], { [Campaign.Fields.status]: status });
90    res.json({ success: true, id: req.params.id, status });
91  } catch (err) {
92    res.status(500).json({ error: err.message });
93  }
94});
95
96app.listen(3000, '0.0.0.0', () => {
97  console.log('Facebook Ads integration server running on port 3000');
98});

1import os
2import time
3import requests
4from functools import wraps
5
6ACCESS_TOKEN = os.environ["FACEBOOK_ACCESS_TOKEN"]
7AD_ACCOUNT_ID = os.environ["FACEBOOK_AD_ACCOUNT_ID"]
8BASE_URL = "https://graph.facebook.com/v18.0"
9
10def with_retry(max_retries=3, initial_delay=1.0):
11    """Decorator for exponential backoff on rate limit errors."""
12    def decorator(func):
13        @wraps(func)
14        def wrapper(*args, **kwargs):
15            delay = initial_delay
16            for attempt in range(max_retries):
17                try:
18                    return func(*args, **kwargs)
19                except requests.HTTPError as e:
20                    status = e.response.status_code
21                    error_code = e.response.json().get('error', {}).get('code', 0)
22                    # Rate limit errors: 17 (app-level), 32 (account-level), 613
23                    if status == 400 and error_code in [17, 32, 613] and attempt < max_retries - 1:
24                        print(f"Rate limited. Waiting {delay}s before retry {attempt + 1}...")
25                        time.sleep(delay)
26                        delay *= 2  # Exponential backoff
27                    else:
28                        raise
29            return None
30        return wrapper
31    return decorator
32
33@with_retry(max_retries=3)
34def get_account_spend(date_preset: str = 'last_30d') -> dict:
35    """Fetch total account spend with rate limit handling."""
36    url = f"{BASE_URL}/{AD_ACCOUNT_ID}/insights"
37    params = {
38        'fields': 'spend,impressions,clicks,reach,actions',
39        'date_preset': date_preset,
40        'access_token': ACCESS_TOKEN
41    }
42    response = requests.get(url, params=params)
43    # Check rate limit usage headers
44    usage = response.headers.get('x-ad-account-usage', '')
45    if usage:
46        print(f"Ad account API usage: {usage}")
47    response.raise_for_status()
48    data = response.json().get('data', [])
49    return data[0] if data else {}
50
51if __name__ == '__main__':
52    spend_data = get_account_spend('last_7d')
53    print(f"Last 7 days spend: ${spend_data.get('spend', '0')}")
54    print(f"Impressions: {spend_data.get('impressions', '0')}")
55    print(f"Clicks: {spend_data.get('clicks', '0')}")