How to Automate Reddit Ad Campaigns using the API

1import requests
2import os
3import logging
4from datetime import datetime, timedelta, timezone
5
6logging.basicConfig(level=logging.INFO)
7log = logging.getLogger('reddit_ads')
8
9USER_AGENT = 'python:com.example.ads-automation:v1.0 (by /u/yourusername)'
10
11class AdsClient:
12    def __init__(self):
13        self.client_id = os.environ['REDDIT_ADS_CLIENT_ID']
14        self.client_secret = os.environ['REDDIT_ADS_CLIENT_SECRET']
15        self.refresh_token_val = os.environ['REDDIT_ADS_REFRESH_TOKEN']
16        self.account_id = os.environ['REDDIT_ADS_ACCOUNT_ID']
17        self.access_token = None
18        self.expiry = datetime.now(timezone.utc)
19
20    def _refresh(self):
21        if datetime.now(timezone.utc) < self.expiry - timedelta(minutes=5):
22            return
23        r = requests.post(
24            'https://www.reddit.com/api/v1/access_token',
25            auth=requests.auth.HTTPBasicAuth(self.client_id, self.client_secret),
26            data={'grant_type': 'refresh_token', 'refresh_token': self.refresh_token_val},
27            headers={'User-Agent': USER_AGENT}
28        )
29        r.raise_for_status()
30        d = r.json()
31        self.access_token = d['access_token']
32        self.expiry = datetime.now(timezone.utc) + timedelta(seconds=d['expires_in'])
33
34    def _headers(self):
35        self._refresh()
36        return {'Authorization': f'Bearer {self.access_token}', 'User-Agent': USER_AGENT}
37
38    def get(self, path, params=None):
39        r = requests.get(f'https://ads-api.reddit.com/api/v2.0{path}',
40                         headers=self._headers(), params=params)
41        r.raise_for_status()
42        return r.json()
43
44    def patch(self, path, body):
45        r = requests.patch(f'https://ads-api.reddit.com/api/v2.0{path}',
46                           headers={**self._headers(), 'Content-Type': 'application/json'},
47                           json=body)
48        r.raise_for_status()
49        return r.json()
50
51def run_daily():
52    client = AdsClient()
53    end = datetime.now(timezone.utc)
54    start = end - timedelta(days=7)
55
56    # Pull 7-day report
57    report = client.get('/reports', {'account_id': client.account_id,
58        'start_date': start.strftime('%Y-%m-%d'), 'end_date': end.strftime('%Y-%m-%d'),
59        'metrics': 'impressions,clicks,spend,ctr,cpm'})
60    metrics = {}
61    for row in report.get('data', []):
62        cid = row.get('campaign_id')
63        if cid not in metrics:
64            metrics[cid] = {'impressions': 0, 'clicks': 0, 'spend': 0.0}
65        metrics[cid]['impressions'] += row.get('impressions', 0)
66        metrics[cid]['clicks'] += row.get('clicks', 0)
67        metrics[cid]['spend'] += float(row.get('spend', 0))
68    for m in metrics.values():
69        m['cpc'] = m['spend'] / m['clicks'] if m['clicks'] > 0 else 0
70
71    # Get campaign details
72    campaigns_data = client.get('/campaigns', {'account_id': client.account_id})
73    cmap = {c['id']: c for c in campaigns_data.get('data', [])}
74
75    # Apply rules
76    changes = []
77    for cid, m in metrics.items():
78        c = cmap.get(cid)
79        if not c or c['status'] == 'COMPLETED':
80            continue
81        if m['cpc'] > 2.50 and c['status'] == 'ACTIVE':
82            client.patch(f'/campaigns/{cid}', {'status': 'PAUSED'})
83            log.info(f'Paused {cid}: CPC=${m["cpc"]:.2f}')
84            changes.append({'id': cid, 'action': 'paused'})
85        elif m['cpc'] < 0.80 and m['clicks'] >= 50 and c['status'] == 'ACTIVE':
86            nb = round(c.get('daily_budget', 0) * 1.20, 2)
87            client.patch(f'/campaigns/{cid}', {'daily_budget': nb})
88            log.info(f'Budget increase {cid}: ${nb}')
89            changes.append({'id': cid, 'action': 'budget_increase', 'new': nb})
90
91    # Report totals
92    total_spend = sum(m['spend'] for m in metrics.values())
93    total_clicks = sum(m['clicks'] for m in metrics.values())
94    avg_cpc = total_spend / total_clicks if total_clicks > 0 else 0
95    log.info(f'Report: spend=${total_spend:.2f} clicks={total_clicks} CPC=${avg_cpc:.3f} changes={len(changes)}')
96
97    # Send to Slack
98    slack_url = os.environ.get('SLACK_WEBHOOK_URL')
99    if slack_url:
100        paused_count = sum(1 for c in changes if c['action'] == 'paused')
101        boosted_count = sum(1 for c in changes if c['action'] == 'budget_increase')
102        msg = (f'Reddit Ads 7-day Report\nSpend: ${total_spend:.2f}  Clicks: {total_clicks}  Avg CPC: ${avg_cpc:.3f}\n'
103               f'Auto-paused: {paused_count}  Budget increases: {boosted_count}')
104        requests.post(slack_url, json={'text': msg})
105
106if __name__ == '__main__':
107    run_daily()