Get HTTP request statistics for all zones in a Cloudflare account

cloudflare_request_stats.py

import csv
import os

import requests

EMAIL = os.getenv("CLOUDFLARE_EMAIL")
API_KEY = os.getenv("CLOUDFLARE_API_KEY")
ACCOUNT_ID = os.getenv("CLOUDFLARE_ACCOUNT_ID")

s = requests.Session()
s.headers.update({"X-Auth-Email": EMAIL, "X-Auth-Key": API_KEY, "Content-Type": "application/json"})

res = s.get(f"https://api.cloudflare.com/client/v4/zones?account.id={ACCOUNT_ID}&per_page=50")  # TODO: add paginations
res.raise_for_status()
zones = res.json()["result"]


fields = ["bytes", "cachedBytes", "cachedRequests", "requests"]

with open("stats.csv", "w") as csf:
    writer = csv.DictWriter(csf, fieldnames=["id", "name"] + fields)
    writer.writeheader()

    for zone in zones:
        fs = '\n'.join(fields)
        query = (
            "{\n"
            "  viewer {\n"
            f"    zones(filter: {{zoneTag: \"{zone['id']}\"}}) {{\n"
            "      httpRequests1dGroups(limit: 10000, filter: {date_geq: \"2020-11-14\", date_lt: \"2020-12-14\"}) {\n"
            "        sum {\n"
            f"         {fs}"
            "        }\n"
            "      }\n"
            "    }\n"
            "  }\n"
            "}"
        )

        res = s.post("https://api.cloudflare.com/client/v4/graphql", json={"query": query})
        res.raise_for_status()
        res = res.json()

        print(zone["id"], zone["name"])

        dd = {
            f: (
                res["data"]["viewer"]["zones"][0]["httpRequests1dGroups"][0]["sum"][f]
                if res["data"]["viewer"]["zones"][0]["httpRequests1dGroups"]
                else 0
            )
            for f in fields
        }

        writer.writerow({"id": zone["id"], "name": zone["name"], **dd})