Scale Dmand AI Enrichment with Batching and Rate Limits

import requests
import time

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://ext-api.dmand.ai/api/v1"

def submit_bulk(npis, webhook_url=None, webhook_mode="batch", custom_data=None):
    """Submit a batch of up to 100 NPIs."""
    payload = {
        "npis": npis,
        "enrichment_email_type": "any",
    }
    if webhook_url:
        payload["webhook"] = {"url": webhook_url, "mode": webhook_mode}
    if custom_data:
        payload["custom_data"] = custom_data

    response = requests.post(
        f"{BASE_URL}/email/bulk",
        headers={
            "Authorization": f"Bearer {API_KEY}",
            "Content-Type": "application/json",
        },
        json=payload,
    )
    response.raise_for_status()
    return response.json()


def chunk_and_submit(all_npis, chunk_size=100):
    """Split a long list of NPIs into batches and submit each."""
    batch_ids = []
    request_ids = []
    for i in range(0, len(all_npis), chunk_size):
        chunk = all_npis[i : i + chunk_size]
        result = submit_bulk(
            npis=chunk,
            webhook_url="https://your-app.com/webhooks/dmand",
            webhook_mode="batch",
            custom_data={"job_id": f"job_{i // chunk_size}"},
        )
        batch_ids.append(result.get("batch_id"))
        for req in result.get("requests", []):
            request_ids.append(req["request_id"])
        # Stay under 100 req/min
        time.sleep(60 / 100)
    return batch_ids, request_ids


# Example: submit 500 NPIs in 5 batches
npis = ["1003158791"] * 500
batch_ids, request_ids = chunk_and_submit(npis)
print("Submitted batches:", batch_ids)

curl https://ext-api.dmand.ai/api/v1/credits \
  -H "Authorization: Bearer YOUR_API_KEY"

{ "balance": 850, "total": 1000, "used": 150 }

import random
import time

def send_with_backoff(request_fn, max_retries=5):
    for attempt in range(max_retries):
        response = request_fn()
        if response.status_code == 202:
            return response
        if response.status_code in (403, 422):
            response.raise_for_status()  # don't retry auth or validation errors
        time.sleep((2 ** attempt) + random.random())
    raise Exception("Max retries exceeded")