Connect Antlytics to Pipedream

Pipedream is a serverless integration platform. Use it to receive Antlytics webhooks and forward data to any destination.

Option A: Webhooks (recommended)

1. In Pipedream, create a new workflow. Choose HTTP / Webhook as the trigger.
2. Copy the unique endpoint URL Pipedream gives you.
3. In your Antlytics dashboard, go to Settings → Webhooks → Add webhook.
4. Paste the URL, select your events, then click Create. Save the signing secret.
5. Click Test in Antlytics — the payload appears immediately in Pipedream's event inspector.
6. Add action steps to route data to Slack, Airtable, HubSpot, or run custom Node.js / Python code.

Example payload (daily summary)

{
  "event": "daily_summary",
  "site_id": "YOUR_SITE_ID",
  "site_name": "example.com",
  "period": "2026-04-11",
  "stats": {
    "visitors": 142,
    "pageviews": 387,
    "bounce_rate": 45,
    "top_pages": [{ "path": "/", "visitors": 80 }],
    "top_referrers": []
  },
  "timestamp": "2026-04-11T09:00:00Z"
}

Reference fields in steps as steps.trigger.event.body.stats.visitors.

Verifying signatures (optional Node.js step)

import crypto from 'crypto';

export default defineComponent({
  async run({ steps }) {
    const secret = process.env.ANTLYTICS_WEBHOOK_SECRET;
    const body = JSON.stringify(steps.trigger.event.body);
    const expected = 'sha256=' + crypto.createHmac('sha256', secret).update(body).digest('hex');
    const received = steps.trigger.event.headers['x-antlytics-signature'];
    if (!crypto.timingSafeEqual(Buffer.from(expected), Buffer.from(received))) {
      throw new Error('Invalid signature');
    }
  }
});

Store the signing secret in Environment Variables under Pipedream project settings.

Option B: API polling via Pipedream scheduler

1. Create a workflow with a Schedule trigger (e.g. daily at 09:00).
2. Add a Node.js step:

import axios from 'axios';

export default defineComponent({
  async run({ steps, $ }) {
    const { data } = await axios.get(
      'https://www.antlytics.com/api/v1/stats',
      {
        params: { site_id: process.env.ANTLYTICS_SITE_ID },
        headers: { Authorization: `Bearer ${process.env.ANTLYTICS_API_TOKEN}` },
      }
    );
    return data;
  }
});

Store ANTLYTICS_SITE_ID and ANTLYTICS_API_TOKEN in Environment Variables.

Need help?

Email support@antlytics.com with your site ID.