diff --git a/apps/gateway/test/index.spec.ts b/apps/gateway/test/index.spec.ts
index e0f1a5f7bd..b46dde3e79 100644
--- a/apps/gateway/test/index.spec.ts
+++ b/apps/gateway/test/index.spec.ts
@@ -1,7 +1,7 @@
-// test/index.spec.ts
-import { SELF, createExecutionContext, env, waitOnExecutionContext } from "cloudflare:test";
 import { describe, expect, it } from "vitest";
 import worker from "../src/index";
+// test/index.spec.ts
+import { SELF, createExecutionContext, env, waitOnExecutionContext } from "cloudflare:test";
 
 // For now, you'll need to do something like this to get a correctly-typed
 // `Request` to pass to `worker.fetch()`.
diff --git a/apps/web/app/(authenticated)/(app)/app/settings/billing/budgets-table.tsx b/apps/web/app/(authenticated)/(app)/app/settings/billing/budgets-table.tsx
new file mode 100644
index 0000000000..fd4c7a399a
--- /dev/null
+++ b/apps/web/app/(authenticated)/(app)/app/settings/billing/budgets-table.tsx
@@ -0,0 +1,66 @@
+"use client";
+
+import { Badge } from "@/components/ui/badge";
+import { Progress } from "@/components/ui/progress";
+import {
+  Table,
+  TableBody,
+  TableCaption,
+  TableCell,
+  TableHead,
+  TableHeader,
+  TableRow,
+} from "@/components/ui/table";
+import { Check, Minus, X } from "lucide-react";
+import type { BudgetsSectionProps } from "./budgets";
+import { DeleteBudgetButton } from "./delete-budget-button";
+import { EditBudgetButton } from "./edit-budget-button";
+
+export const BudgetsTable: React.FC<BudgetsSectionProps> = ({ budgets, currentBilling }) => {
+  return (
+    <Table>
+      {budgets.length === 0 ? <TableCaption>No budgets found</TableCaption> : null}
+      <TableHeader>
+        <TableRow>
+          <TableHead>Enabled</TableHead>
+          <TableHead>Name</TableHead>
+          <TableHead>Budget</TableHead>
+          <TableHead>Amount used</TableHead>
+          <TableHead>Current vs. budgeted</TableHead>
+          <TableHead />
+        </TableRow>
+      </TableHeader>
+      <TableBody>
+        {budgets.map((budget, i) => {
+          const usage = Math.floor((currentBilling / budget.fixedAmount) * 10000) / 100;
+
+          return (
+            // biome-ignore lint/suspicious/noArrayIndexKey: I got nothing better right now
+            <TableRow key={i}>
+              <TableCell>{budget.enabled ? <Check /> : <X />}</TableCell>
+              <TableCell className="w-fit">
+                {budget.name ? (
+                  <Badge variant="secondary">{budget.name}</Badge>
+                ) : (
+                  <Minus className="w-4 h-4 text-gray-300" />
+                )}
+              </TableCell>
+              <TableCell>${budget.fixedAmount}</TableCell>
+              <TableCell>${currentBilling}</TableCell>
+              <TableCell>
+                <div className="flex items-center gap-2 text-content-subtle text-xs max-w-40">
+                  <Progress value={usage} className="h-2" />
+                  {`${usage}%`}
+                </div>
+              </TableCell>
+              <TableCell className="flex items-center gap-2">
+                <EditBudgetButton budget={budget} />
+                <DeleteBudgetButton budgetId={budget.id} />
+              </TableCell>
+            </TableRow>
+          );
+        })}
+      </TableBody>
+    </Table>
+  );
+};
diff --git a/apps/web/app/(authenticated)/(app)/app/settings/billing/budgets.tsx b/apps/web/app/(authenticated)/(app)/app/settings/billing/budgets.tsx
new file mode 100644
index 0000000000..8fb6065c51
--- /dev/null
+++ b/apps/web/app/(authenticated)/(app)/app/settings/billing/budgets.tsx
@@ -0,0 +1,29 @@
+import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "@/components/ui/card";
+import type { Budget } from "@unkey/db";
+import { BudgetsTable } from "./budgets-table";
+import { CreateBudgetButton } from "./create-budget-button";
+
+export type BudgetsSectionProps = {
+  currentBilling: number;
+  budgets: Budget[];
+};
+
+export function BudgetsSection({ currentBilling, budgets }: BudgetsSectionProps) {
+  return (
+    <Card>
+      <CardHeader>
+        <CardTitle className="flex justify-between items-center">
+          Budgets
+          <CreateBudgetButton />
+        </CardTitle>
+        <CardDescription>
+          Set custom budgets that alert you when your costs and usage exceed your budgeted amount.
+        </CardDescription>
+      </CardHeader>
+
+      <CardContent>
+        <BudgetsTable currentBilling={currentBilling} budgets={budgets} />
+      </CardContent>
+    </Card>
+  );
+}
diff --git a/apps/web/app/(authenticated)/(app)/app/settings/billing/create-budget-button.tsx b/apps/web/app/(authenticated)/(app)/app/settings/billing/create-budget-button.tsx
new file mode 100644
index 0000000000..f82025abb3
--- /dev/null
+++ b/apps/web/app/(authenticated)/(app)/app/settings/billing/create-budget-button.tsx
@@ -0,0 +1,188 @@
+"use client";
+
+import { Loading } from "@/components/dashboard/loading";
+import { Button } from "@/components/ui/button";
+
+import {
+  Dialog,
+  DialogContent,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+  DialogTrigger,
+} from "@/components/ui/dialog";
+import {
+  Form,
+  FormControl,
+  FormDescription,
+  FormField,
+  FormItem,
+  FormLabel,
+  FormMessage,
+} from "@/components/ui/form";
+import { Input } from "@/components/ui/input";
+import { Textarea } from "@/components/ui/textarea";
+import { toast } from "@/components/ui/toaster";
+import { trpc } from "@/lib/trpc/client";
+import { zodResolver } from "@hookform/resolvers/zod";
+import { useRouter } from "next/navigation";
+import { useState } from "react";
+import { useForm } from "react-hook-form";
+import { z } from "zod";
+
+export const createBudgetFormSchema = z.object({
+  name: z.string().optional(),
+  fixedAmount: z.coerce
+    .number({
+      errorMap: (issue, { defaultError }) => ({
+        message:
+          issue.code === "invalid_type" ? "Budget amount must be greater than 0" : defaultError,
+      }),
+    })
+    .positive({ message: "Budget amount must be greater than 0" }),
+  additionalEmails: z
+    .string()
+    .optional()
+    .refine(
+      (val) =>
+        !val ||
+        z.array(z.string().email("Invalid email format")).max(10).safeParse(val.split(",")).success,
+      "Invalid email list. Ensure emails are correctly formatted and do not exceed 10.",
+    ),
+});
+
+export const CreateBudgetButton: React.FC<React.ButtonHTMLAttributes<HTMLButtonElement>> = (
+  props,
+) => {
+  const router = useRouter();
+
+  const [isOpen, setIsOpen] = useState(false);
+
+  const form = useForm<z.infer<typeof createBudgetFormSchema>>({
+    resolver: zodResolver(createBudgetFormSchema),
+    defaultValues: {
+      additionalEmails: "",
+    },
+  });
+
+  const createBudget = trpc.budget.create.useMutation({
+    onSuccess() {
+      toast.success("Your Budget has been created");
+
+      router.refresh();
+
+      setIsOpen(false);
+    },
+    onError(err) {
+      console.error(err);
+      toast.error(err.message);
+    },
+  });
+
+  async function onSubmit(values: z.infer<typeof createBudgetFormSchema>) {
+    await createBudget.mutateAsync({
+      ...values,
+      additionalEmails: values.additionalEmails?.split(",").filter(Boolean) || undefined,
+    });
+  }
+
+  function onOpenChange(open: boolean) {
+    if (open) {
+      form.reset({
+        fixedAmount: undefined,
+        additionalEmails: "",
+      });
+    }
+    setIsOpen(open);
+  }
+
+  return (
+    <Dialog open={isOpen} onOpenChange={onOpenChange}>
+      <DialogTrigger asChild>
+        <Button className="flex-row items-center gap-1 font-semibold " {...props}>
+          Create Budget
+        </Button>
+      </DialogTrigger>
+
+      <DialogContent className="w-11/12 max-sm: ">
+        <DialogHeader>
+          <DialogTitle>Create a new Budget</DialogTitle>
+        </DialogHeader>
+        <Form {...form}>
+          <form onSubmit={form.handleSubmit(onSubmit)} className="space-y-4">
+            <FormField
+              control={form.control}
+              name="name"
+              render={({ field }) => (
+                <FormItem>
+                  <FormLabel>Budget Name</FormLabel>
+                  <FormControl>
+                    <Input {...field} autoComplete="off" />
+                  </FormControl>
+                  <FormDescription>Provide a descriptive name for this budget.</FormDescription>
+                  <FormMessage />
+                </FormItem>
+              )}
+            />
+
+            <FormField
+              control={form.control}
+              name="fixedAmount"
+              render={({ field }) => (
+                <FormItem>
+                  <FormLabel>Budget amount ($)</FormLabel>
+                  <FormControl>
+                    <Input
+                      type="number"
+                      min={0}
+                      className="max-w-[120px]"
+                      {...field}
+                      autoComplete="off"
+                      placeholder="0.00"
+                      step="0.01"
+                    />
+                  </FormControl>
+                  <FormDescription>Enter your budgeted amount.</FormDescription>
+                  <FormMessage />
+                </FormItem>
+              )}
+            />
+
+            <FormField
+              control={form.control}
+              name="additionalEmails"
+              render={({ field }) => (
+                <FormItem>
+                  <FormLabel>Email recipients</FormLabel>
+                  <FormControl>
+                    <Textarea
+                      rows={3}
+                      {...field}
+                      autoComplete="off"
+                      placeholder="Separate email addresses using commas"
+                    />
+                  </FormControl>
+                  <FormDescription>
+                    Specify up to 10 additional email recipients you want to notify when the
+                    threshold has exceeded. The account owner will also get notified.
+                  </FormDescription>
+                  <FormMessage />
+                </FormItem>
+              )}
+            />
+
+            <DialogFooter className="flex-row justify-end gap-2 pt-4 ">
+              <Button
+                disabled={createBudget.isLoading || form.formState.isSubmitting}
+                className="mt-4 "
+                type="submit"
+              >
+                {createBudget.isLoading ? <Loading /> : "Create"}
+              </Button>
+            </DialogFooter>
+          </form>
+        </Form>
+      </DialogContent>
+    </Dialog>
+  );
+};
diff --git a/apps/web/app/(authenticated)/(app)/app/settings/billing/delete-budget-button.tsx b/apps/web/app/(authenticated)/(app)/app/settings/billing/delete-budget-button.tsx
new file mode 100644
index 0000000000..adb8ef9885
--- /dev/null
+++ b/apps/web/app/(authenticated)/(app)/app/settings/billing/delete-budget-button.tsx
@@ -0,0 +1,74 @@
+"use client";
+import { Button } from "@/components/ui/button";
+import React, { useState } from "react";
+
+import { toast } from "@/components/ui/toaster";
+
+import { Loading } from "@/components/dashboard/loading";
+import {
+  Dialog,
+  DialogContent,
+  DialogDescription,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from "@/components/ui/dialog";
+import { trpc } from "@/lib/trpc/client";
+import { Trash } from "lucide-react";
+import { useRouter } from "next/navigation";
+
+type Props = {
+  budgetId: string;
+};
+
+export const DeleteBudgetButton: React.FC<Props> = ({ budgetId }) => {
+  const router = useRouter();
+  const [isOpen, setIsOpen] = useState(false);
+
+  const deleteBudget = trpc.budget.delete.useMutation({
+    onSuccess() {
+      toast.success("Budget deleted");
+
+      router.refresh();
+
+      setIsOpen(false);
+    },
+    onError(error) {
+      console.error(error);
+      toast.error(error.message);
+    },
+  });
+
+  return (
+    <>
+      <Button size="icon" type="button" onClick={() => setIsOpen(true)} variant="alert">
+        <Trash className="w-4 h-4" />
+      </Button>
+
+      <Dialog open={isOpen} onOpenChange={setIsOpen}>
+        <DialogContent className="border-[#b80f07]">
+          <DialogHeader>
+            <DialogTitle>Delete Budget</DialogTitle>
+            <DialogDescription>
+              This budget will be deleted. This action cannot be undone.
+            </DialogDescription>
+          </DialogHeader>
+
+          <DialogFooter className="justify-end">
+            <Button type="button" onClick={() => setIsOpen(false)} variant="secondary">
+              Cancel
+            </Button>
+            <Button
+              type="submit"
+              variant="alert"
+              disabled={deleteBudget.isLoading}
+              onClick={() => deleteBudget.mutate({ budgetId })}
+            >
+              {deleteBudget.isLoading ? <Loading /> : "Delete Budget"}
+            </Button>
+          </DialogFooter>
+        </DialogContent>
+      </Dialog>
+    </>
+  );
+};
diff --git a/apps/web/app/(authenticated)/(app)/app/settings/billing/edit-budget-button.tsx b/apps/web/app/(authenticated)/(app)/app/settings/billing/edit-budget-button.tsx
new file mode 100644
index 0000000000..c2eeb137bb
--- /dev/null
+++ b/apps/web/app/(authenticated)/(app)/app/settings/billing/edit-budget-button.tsx
@@ -0,0 +1,201 @@
+"use client";
+
+import { Loading } from "@/components/dashboard/loading";
+import { Button } from "@/components/ui/button";
+
+import {
+  Dialog,
+  DialogContent,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from "@/components/ui/dialog";
+import {
+  Form,
+  FormControl,
+  FormDescription,
+  FormField,
+  FormItem,
+  FormLabel,
+  FormMessage,
+} from "@/components/ui/form";
+import { Input } from "@/components/ui/input";
+import { Switch } from "@/components/ui/switch";
+import { Textarea } from "@/components/ui/textarea";
+import { toast } from "@/components/ui/toaster";
+import { trpc } from "@/lib/trpc/client";
+import { zodResolver } from "@hookform/resolvers/zod";
+import type { Budget } from "@unkey/db";
+import { Edit } from "lucide-react";
+import { useRouter } from "next/navigation";
+import { useState } from "react";
+import { useForm } from "react-hook-form";
+import { z } from "zod";
+import { createBudgetFormSchema } from "./create-budget-button";
+
+const editBudgetFormSchema = createBudgetFormSchema.extend({
+  enabled: z.boolean(),
+});
+
+type Props = {
+  budget: Budget;
+};
+
+export const EditBudgetButton: React.FC<Props> = ({ budget }) => {
+  const router = useRouter();
+
+  const [isOpen, setIsOpen] = useState(false);
+
+  const form = useForm<z.infer<typeof editBudgetFormSchema>>({
+    resolver: zodResolver(editBudgetFormSchema),
+    defaultValues: {
+      name: budget.name || "",
+      enabled: budget.enabled,
+      fixedAmount: budget.fixedAmount,
+      additionalEmails: budget.data.additionalEmails?.join(",") || "",
+    },
+  });
+
+  const editBudget = trpc.budget.update.useMutation({
+    onSuccess() {
+      toast.success("Your Budget has been updated");
+
+      router.refresh();
+
+      setIsOpen(false);
+    },
+    onError(err) {
+      console.error(err);
+      toast.error(err.message);
+    },
+  });
+
+  async function onSubmit(values: z.infer<typeof editBudgetFormSchema>) {
+    await editBudget.mutateAsync({
+      ...values,
+      budgetId: budget.id,
+      additionalEmails: values.additionalEmails?.split(",").filter(Boolean) || undefined,
+    });
+  }
+
+  function onOpenChange(open: boolean) {
+    if (open) {
+      form.reset({
+        fixedAmount: undefined,
+        additionalEmails: "",
+      });
+    }
+    setIsOpen(open);
+  }
+
+  return (
+    <Dialog open={isOpen} onOpenChange={onOpenChange}>
+      <Button size="icon" type="button" onClick={() => setIsOpen(true)} variant="secondary">
+        <Edit className="w-4 h-4" />
+      </Button>
+
+      <DialogContent className="w-11/12 max-sm: ">
+        <DialogHeader>
+          <DialogTitle>Edit Budget</DialogTitle>
+        </DialogHeader>
+        <Form {...form}>
+          <form onSubmit={form.handleSubmit(onSubmit)} className="space-y-4">
+            <FormField
+              control={form.control}
+              name="enabled"
+              render={({ field }) => (
+                <FormItem className="w-full">
+                  <div className="flex items-center gap-4">
+                    <FormControl>
+                      <Switch
+                        id="enabled"
+                        checked={form.getValues("enabled")}
+                        onCheckedChange={(e) => {
+                          field.onChange(e);
+                        }}
+                      />
+                    </FormControl>{" "}
+                    <FormLabel htmlFor="enabled">
+                      {form.getValues("enabled") ? "Enabled" : "Disabled"}
+                    </FormLabel>
+                  </div>
+                </FormItem>
+              )}
+            />
+
+            <FormField
+              control={form.control}
+              name="name"
+              render={({ field }) => (
+                <FormItem>
+                  <FormLabel>Budget Name</FormLabel>
+                  <FormControl>
+                    <Input {...field} autoComplete="off" />
+                  </FormControl>
+                  <FormDescription>Provide a descriptive name for this budget.</FormDescription>
+                  <FormMessage />
+                </FormItem>
+              )}
+            />
+
+            <FormField
+              control={form.control}
+              name="fixedAmount"
+              render={({ field }) => (
+                <FormItem>
+                  <FormLabel>Budget amount ($)</FormLabel>
+                  <FormControl>
+                    <Input
+                      type="number"
+                      min={0}
+                      className="max-w-[120px]"
+                      {...field}
+                      autoComplete="off"
+                      placeholder="0.00"
+                      step="0.01"
+                    />
+                  </FormControl>
+                  <FormDescription>Enter your budgeted amount.</FormDescription>
+                  <FormMessage />
+                </FormItem>
+              )}
+            />
+
+            <FormField
+              control={form.control}
+              name="additionalEmails"
+              render={({ field }) => (
+                <FormItem>
+                  <FormLabel>Email recipients</FormLabel>
+                  <FormControl>
+                    <Textarea
+                      rows={3}
+                      {...field}
+                      autoComplete="off"
+                      placeholder="Separate email addresses using commas"
+                    />
+                  </FormControl>
+                  <FormDescription>
+                    Specify up to 10 additional email recipients you want to notify when the
+                    threshold has exceeded. The account owner will also get notified.
+                  </FormDescription>
+                  <FormMessage />
+                </FormItem>
+              )}
+            />
+
+            <DialogFooter className="flex-row justify-end gap-2 pt-4 ">
+              <Button
+                disabled={editBudget.isLoading || form.formState.isSubmitting}
+                className="mt-4 "
+                type="submit"
+              >
+                {editBudget.isLoading ? <Loading /> : "Save"}
+              </Button>
+            </DialogFooter>
+          </form>
+        </Form>
+      </DialogContent>
+    </Dialog>
+  );
+};
diff --git a/apps/web/app/(authenticated)/(app)/app/settings/billing/page.tsx b/apps/web/app/(authenticated)/(app)/app/settings/billing/page.tsx
index 8f2e2d3cb4..c08efd2408 100644
--- a/apps/web/app/(authenticated)/(app)/app/settings/billing/page.tsx
+++ b/apps/web/app/(authenticated)/(app)/app/settings/billing/page.tsx
@@ -13,11 +13,18 @@ import { type Workspace, db } from "@/lib/db";
 import { stripeEnv } from "@/lib/env";
 import { activeKeys, ratelimits, verifications } from "@/lib/tinybird";
 import { cn } from "@/lib/utils";
-import { type BillingTier, QUOTA, calculateTieredPrices } from "@unkey/billing";
+import {
+  type BillingTier,
+  QUOTA,
+  calculateTieredPrices,
+  forecastUsage,
+  getCurrentUsageBill,
+} from "@unkey/billing";
 import { Check, ExternalLink } from "lucide-react";
 import Link from "next/link";
 import { redirect } from "next/navigation";
 import Stripe from "stripe";
+import { BudgetsSection } from "./budgets";
 
 export const revalidate = 0;
 
@@ -202,7 +209,10 @@ const ProUsage: React.FC<{ workspace: Workspace }> = async ({ workspace }) => {
   const year = startOfMonth.getUTCFullYear();
   const month = startOfMonth.getUTCMonth() + 1;
 
-  const [usedActiveKeys, usedVerifications, usedRatelimits] = await Promise.all([
+  const [budgets, usedActiveKeys, usedVerifications, usedRatelimits] = await Promise.all([
+    db.query.budgets.findMany({
+      where: (table, { eq }) => eq(table.workspaceId, workspace.id),
+    }),
     activeKeys({
       workspaceId: workspace.id,
       year,
@@ -220,103 +230,92 @@ const ProUsage: React.FC<{ workspace: Workspace }> = async ({ workspace }) => {
     }).then((res) => res.data.at(0)?.success ?? 0),
   ]);
 
-  let currentPrice = 0;
-  let estimatedTotalPrice = 0;
-  if (workspace.subscriptions?.plan) {
-    const cost = Number.parseFloat(workspace.subscriptions.plan.cents);
-    currentPrice += cost;
-    estimatedTotalPrice += cost; // does not scale
-  }
-  if (workspace.subscriptions?.support) {
-    const cost = Number.parseFloat(workspace.subscriptions.support.cents);
-    currentPrice += cost;
-    estimatedTotalPrice += cost; // does not scale
-  }
-  if (workspace.subscriptions?.activeKeys) {
-    const cost = calculateTieredPrices(workspace.subscriptions.activeKeys.tiers, usedActiveKeys);
-    if (cost.err) {
-      return <div className="text-red-500">{cost.err.message}</div>;
-    }
-    currentPrice += cost.val.totalCentsEstimate;
-  }
-  if (workspace.subscriptions?.verifications) {
-    const cost = calculateTieredPrices(
-      workspace.subscriptions.verifications.tiers,
-      usedVerifications,
-    );
-    if (cost.err) {
-      return <div className="text-red-500">{cost.err.message}</div>;
-    }
-    currentPrice += cost.val.totalCentsEstimate;
-    estimatedTotalPrice += forecastUsage(cost.val.totalCentsEstimate);
+  const { currentPrice, estimatedTotalPrice, error } = getCurrentUsageBill(
+    {
+      activeKeys: usedActiveKeys,
+      verifications: usedVerifications,
+      ratelimits: usedRatelimits,
+    },
+    workspace.subscriptions,
+  );
+
+  if (error) {
+    return <div className="text-red-500">{error}</div>;
   }
 
   return (
-    <Card>
-      <CardHeader>
-        <CardTitle>Pro plan</CardTitle>
-        <CardDescription>
-          Current billing cycle:{" "}
-          <span className="font-medium text-primary">
-            {startOfMonth.toLocaleString("en-US", { month: "long", year: "numeric" })}
-          </span>{" "}
-        </CardDescription>
-      </CardHeader>
+    <div className="flex flex-col gap-8 ">
+      <Card>
+        <CardHeader>
+          <CardTitle>Pro plan</CardTitle>
+          <CardDescription>
+            Current billing cycle:{" "}
+            <span className="font-medium text-primary">
+              {startOfMonth.toLocaleString("en-US", { month: "long", year: "numeric" })}
+            </span>{" "}
+          </CardDescription>
+        </CardHeader>
+
+        <CardContent>
+          <ol className="flex flex-col space-y-6">
+            {workspace.subscriptions?.plan ? (
+              <LineItem title="Pro plan" cents={workspace.subscriptions.plan.cents} />
+            ) : null}
+            {workspace.subscriptions?.support ? (
+              <LineItem
+                title="Professional support"
+                cents={workspace.subscriptions.support.cents}
+              />
+            ) : null}
+            {workspace.subscriptions?.activeKeys ? (
+              <MeteredLineItem
+                displayPrice
+                title="Active keys"
+                tiers={workspace.subscriptions.activeKeys.tiers}
+                used={usedActiveKeys}
+                max={workspace.plan === "free" ? QUOTA.free.maxActiveKeys : undefined}
+              />
+            ) : null}
+            {workspace.subscriptions?.verifications ? (
+              <MeteredLineItem
+                displayPrice
+                title="Verifications"
+                tiers={workspace.subscriptions.verifications.tiers}
+                used={usedVerifications}
+                max={workspace.plan === "free" ? QUOTA.free.maxVerifications : undefined}
+                forecast
+              />
+            ) : null}
+            {workspace.subscriptions?.ratelimits ? (
+              <MeteredLineItem
+                displayPrice
+                title="Ratelimits"
+                tiers={workspace.subscriptions.ratelimits.tiers}
+                used={usedRatelimits}
+                max={workspace.plan === "free" ? QUOTA.free.maxRatelimits : undefined}
+                forecast
+              />
+            ) : null}
+          </ol>
+        </CardContent>
+        <CardFooter className="flex flex-col gap-4">
+          <div className="flex items-center justify-between w-full">
+            <span className="text-sm font-semibold text-content">Current Total</span>
+            <span className="text-sm font-semibold tabular-nums text-content">
+              {formatCentsToDollar(currentPrice)}
+            </span>
+          </div>
+          <div className="flex items-center justify-between w-full">
+            <span className="text-xs text-content-subtle">Estimated by end of month</span>
+            <span className="text-xs tabular-nums text-content-subtle">
+              {formatCentsToDollar(estimatedTotalPrice)}
+            </span>
+          </div>
+        </CardFooter>
+      </Card>
 
-      <CardContent>
-        <ol className="flex flex-col space-y-6">
-          {workspace.subscriptions?.plan ? (
-            <LineItem title="Pro plan" cents={workspace.subscriptions.plan.cents} />
-          ) : null}
-          {workspace.subscriptions?.support ? (
-            <LineItem title="Professional support" cents={workspace.subscriptions.support.cents} />
-          ) : null}
-          {workspace.subscriptions?.activeKeys ? (
-            <MeteredLineItem
-              displayPrice
-              title="Active keys"
-              tiers={workspace.subscriptions.activeKeys.tiers}
-              used={usedActiveKeys}
-              max={workspace.plan === "free" ? QUOTA.free.maxActiveKeys : undefined}
-            />
-          ) : null}
-          {workspace.subscriptions?.verifications ? (
-            <MeteredLineItem
-              displayPrice
-              title="Verifications"
-              tiers={workspace.subscriptions.verifications.tiers}
-              used={usedVerifications}
-              max={workspace.plan === "free" ? QUOTA.free.maxVerifications : undefined}
-              forecast
-            />
-          ) : null}
-          {workspace.subscriptions?.ratelimits ? (
-            <MeteredLineItem
-              displayPrice
-              title="Ratelimits"
-              tiers={workspace.subscriptions.ratelimits.tiers}
-              used={usedRatelimits}
-              max={workspace.plan === "free" ? QUOTA.free.maxRatelimits : undefined}
-              forecast
-            />
-          ) : null}
-        </ol>
-      </CardContent>
-      <CardFooter className="flex flex-col gap-4">
-        <div className="flex items-center justify-between w-full">
-          <span className="text-sm font-semibold text-content">Current Total</span>
-          <span className="text-sm font-semibold tabular-nums text-content">
-            {formatCentsToDollar(currentPrice)}
-          </span>
-        </div>
-        <div className="flex items-center justify-between w-full">
-          <span className="text-xs text-content-subtle">Estimated by end of month</span>
-          <span className="text-xs tabular-nums text-content-subtle">
-            {formatCentsToDollar(estimatedTotalPrice)}
-          </span>
-        </div>
-      </CardFooter>
-    </Card>
+      <BudgetsSection currentBilling={currentPrice / 100} budgets={budgets} />
+    </div>
   );
 };
 
@@ -338,20 +337,6 @@ const LineItem: React.FC<{
   </div>
 );
 
-function forecastUsage(currentUsage: number): number {
-  const t = new Date();
-  t.setUTCDate(1);
-  t.setUTCHours(0, 0, 0, 0);
-
-  const start = t.getTime();
-  t.setUTCMonth(t.getUTCMonth() + 1);
-  const end = t.getTime() - 1;
-
-  const passed = (Date.now() - start) / (end - start);
-
-  return currentUsage * (1 + 1 / passed);
-}
-
 const MeteredLineItem: React.FC<{
   displayPrice?: boolean;
   title: string;
@@ -473,7 +458,7 @@ function percentage(num: number, total: number): `${number}%` {
 }
 
 const CreditCard: React.FC<{ paymentMethod: Stripe.PaymentMethod }> = ({ paymentMethod }) => (
-  <div className="aspect-[86/54] max-w-[320px] border border-gray-200 dark:border-gray-800 justify-between rounded-lg bg-gradient-to-tr from-gray-200/70 dark:from-black to-gray-100 dark:to-gray-900 dark:border dark:border-gray-800  shadow-lg p-8 ">
+  <div className="aspect-[86/54] max-w-[320px] border border-gray-200 justify-between rounded-lg bg-gradient-to-tr from-gray-200/70 dark:from-black to-gray-100 dark:to-gray-900 dark:border dark:border-gray-800  shadow-lg p-8 ">
     <div className="mt-16 font-mono text-content whitespace-nowrap">
       •••• •••• •••• {paymentMethod.card?.last4}
     </div>
@@ -488,7 +473,7 @@ const CreditCard: React.FC<{ paymentMethod: Stripe.PaymentMethod }> = ({ payment
 );
 
 const MissingCreditCard: React.FC = () => (
-  <div className="relative aspect-[86/54] max-w-[320px] border border-gray-200 dark:border-gray-800 justify-between rounded-lg bg-gradient-to-tr from-gray-200/70 dark:from-black to-gray-100 dark:to-gray-900 dark:border dark:border-gray-800  shadow-lg p-8">
+  <div className="relative aspect-[86/54] max-w-[320px] border border-gray-200 justify-between rounded-lg bg-gradient-to-tr from-gray-200/70 dark:from-black to-gray-100 dark:to-gray-900 dark:border dark:border-gray-800  shadow-lg p-8">
     <div className="z-50 mt-16 font-mono text-content whitespace-nowrap blur-sm">
       •••• •••• •••• ••••
     </div>
diff --git a/apps/web/lib/charts/useTooltip.ts b/apps/web/lib/charts/useTooltip.ts
index 089f9853d3..bcde8cc375 100644
--- a/apps/web/lib/charts/useTooltip.ts
+++ b/apps/web/lib/charts/useTooltip.ts
@@ -1,6 +1,6 @@
 "use client";
 import { localPoint } from "@visx/event";
-import { TooltipWithBounds, useTooltipInPortal, useTooltip as useVisxTooltip } from "@visx/tooltip";
+import { TooltipWithBounds, useTooltip as useVisxTooltip, useTooltipInPortal } from "@visx/tooltip";
 import { bisector } from "d3-array";
 import { useCallback } from "react";
 import type { ChartContext, ChartTooltipContext, Datum, Series, TimeSeriesDatum } from "./types";
diff --git a/apps/web/lib/trpc/routers/budget/create.ts b/apps/web/lib/trpc/routers/budget/create.ts
new file mode 100644
index 0000000000..7dd68d362e
--- /dev/null
+++ b/apps/web/lib/trpc/routers/budget/create.ts
@@ -0,0 +1,43 @@
+import { db, schema } from "@/lib/db";
+import { TRPCError } from "@trpc/server";
+import { newId } from "@unkey/id";
+import { z } from "zod";
+
+import { auth, t } from "../../trpc";
+
+export const createBudgetInputSchema = z.object({
+  name: z.string().optional(),
+  type: z.enum(["soft", "hard"]).default("soft"),
+  fixedAmount: z.number().positive(),
+  additionalEmails: z.array(z.string().email()).max(10).optional(),
+});
+
+export const createBudget = t.procedure
+  .use(auth)
+  .input(createBudgetInputSchema)
+  .mutation(async ({ ctx, input }) => {
+    const workspace = await db.query.workspaces.findFirst({
+      where: (table, { and, eq, isNull }) =>
+        and(eq(table.tenantId, ctx.tenant.id), isNull(table.deletedAt)),
+    });
+    if (!workspace) {
+      throw new TRPCError({
+        code: "NOT_FOUND",
+        message: "workspace not found",
+      });
+    }
+
+    const budgetId = newId("budget");
+
+    await db.insert(schema.budgets).values({
+      id: budgetId,
+      name: input.name,
+      type: input.type,
+      fixedAmount: input.fixedAmount,
+      data: {
+        additionalEmails: input.additionalEmails,
+      },
+      workspaceId: workspace.id,
+      createdAt: new Date(),
+    });
+  });
diff --git a/apps/web/lib/trpc/routers/budget/delete.ts b/apps/web/lib/trpc/routers/budget/delete.ts
new file mode 100644
index 0000000000..40885a2670
--- /dev/null
+++ b/apps/web/lib/trpc/routers/budget/delete.ts
@@ -0,0 +1,29 @@
+import { db, eq, schema } from "@/lib/db";
+import { TRPCError } from "@trpc/server";
+import { z } from "zod";
+
+import { auth, t } from "../../trpc";
+
+export const deleteBudget = t.procedure
+  .use(auth)
+  .input(
+    z.object({
+      budgetId: z.string(),
+    }),
+  )
+  .mutation(async ({ ctx, input }) => {
+    const budget = await db.query.budgets.findFirst({
+      where: (table, { eq }) => eq(table.id, input.budgetId),
+      with: {
+        workspace: true,
+      },
+    });
+    if (!budget) {
+      throw new TRPCError({ message: "budget not found", code: "NOT_FOUND" });
+    }
+    if (budget.workspace.tenantId !== ctx.tenant.id) {
+      throw new TRPCError({ message: "budget not found", code: "NOT_FOUND" });
+    }
+
+    await db.delete(schema.budgets).where(eq(schema.budgets.id, input.budgetId));
+  });
diff --git a/apps/web/lib/trpc/routers/budget/update.ts b/apps/web/lib/trpc/routers/budget/update.ts
new file mode 100644
index 0000000000..4e5c6a8d8e
--- /dev/null
+++ b/apps/web/lib/trpc/routers/budget/update.ts
@@ -0,0 +1,42 @@
+import { db, eq, schema } from "@/lib/db";
+import { TRPCError } from "@trpc/server";
+import { z } from "zod";
+
+import { auth, t } from "../../trpc";
+import { createBudgetInputSchema } from "./create";
+
+export const updateBudget = t.procedure
+  .use(auth)
+  .input(
+    createBudgetInputSchema.extend({
+      budgetId: z.string(),
+      enabled: z.boolean(),
+    }),
+  )
+  .mutation(async ({ ctx, input }) => {
+    const budget = await db.query.budgets.findFirst({
+      where: (table, { eq }) => eq(table.id, input.budgetId),
+      with: {
+        workspace: true,
+      },
+    });
+    if (!budget) {
+      throw new TRPCError({ message: "budget not found", code: "NOT_FOUND" });
+    }
+    if (budget.workspace.tenantId !== ctx.tenant.id) {
+      throw new TRPCError({ message: "budget not found", code: "NOT_FOUND" });
+    }
+
+    await db
+      .update(schema.budgets)
+      .set({
+        enabled: input.enabled,
+        name: input.name,
+        type: input.type,
+        fixedAmount: input.fixedAmount,
+        data: {
+          additionalEmails: input.additionalEmails,
+        },
+      })
+      .where(eq(schema.budgets.id, input.budgetId));
+  });
diff --git a/apps/web/lib/trpc/routers/index.ts b/apps/web/lib/trpc/routers/index.ts
index 934ac759b9..667e29905d 100644
--- a/apps/web/lib/trpc/routers/index.ts
+++ b/apps/web/lib/trpc/routers/index.ts
@@ -3,6 +3,9 @@ import { createApi } from "./api/create";
 import { deleteApi } from "./api/delete";
 import { updateApiIpWhitelist } from "./api/updateIpWhitelist";
 import { updateApiName } from "./api/updateName";
+import { createBudget } from "./budget/create";
+import { deleteBudget } from "./budget/delete";
+import { updateBudget } from "./budget/update";
 import { createGateway } from "./gateway/create";
 import { createKey } from "./key/create";
 import { createRootKey } from "./key/createRootKey";
@@ -114,6 +117,11 @@ export const router = t.router({
       delete: deleteOverride,
     }),
   }),
+  budget: t.router({
+    create: createBudget,
+    update: updateBudget,
+    delete: deleteBudget,
+  }),
 });
 
 // export type definition of API
diff --git a/apps/workflows/jobs/end-trials.ts b/apps/workflows/jobs/end-trials.ts
index 80fa13fb08..a12041c944 100644
--- a/apps/workflows/jobs/end-trials.ts
+++ b/apps/workflows/jobs/end-trials.ts
@@ -1,8 +1,8 @@
+import { getClerkOrganizationUsers } from "@/lib/clerk";
 import { connectDatabase, eq, schema } from "@/lib/db";
 import { env } from "@/lib/env";
 import { Tinybird } from "@/lib/tinybird";
 import { client } from "@/trigger";
-import { clerkClient } from "@clerk/nextjs";
 import { cronTrigger } from "@trigger.dev/sdk";
 import { Slack } from "@trigger.dev/slack";
 import { Resend } from "@unkey/resend";
@@ -71,7 +71,7 @@ client.defineJob({
       });
 
       const users = await io.runTask(`get users for workspace ${ws.id}`, () =>
-        getUsers(ws.tenantId),
+        getClerkOrganizationUsers(ws.tenantId),
       );
 
       for await (const user of users) {
@@ -91,32 +91,3 @@ client.defineJob({
     return {};
   },
 });
-
-async function getUsers(tenantId: string): Promise<{ id: string; email: string; name: string }[]> {
-  const userIds: string[] = [];
-  if (tenantId.startsWith("org_")) {
-    const members = await clerkClient.organizations.getOrganizationMembershipList({
-      organizationId: tenantId,
-    });
-    for (const m of members) {
-      userIds.push(m.publicUserData!.userId);
-    }
-  } else {
-    userIds.push(tenantId);
-  }
-
-  return await Promise.all(
-    userIds.map(async (userId) => {
-      const user = await clerkClient.users.getUser(userId);
-      const email = user.emailAddresses.at(0)?.emailAddress;
-      if (!email) {
-        throw new Error(`user ${user.id} does not have an email`);
-      }
-      return {
-        id: user.id,
-        name: user.firstName ?? user.username ?? "there",
-        email,
-      };
-    }),
-  );
-}
diff --git a/apps/workflows/jobs/index.ts b/apps/workflows/jobs/index.ts
index 000a264ed9..7c07036a92 100644
--- a/apps/workflows/jobs/index.ts
+++ b/apps/workflows/jobs/index.ts
@@ -6,3 +6,4 @@ export * from "./invoicing";
 export * from "./refill-daily";
 export * from "./refill-monthly";
 export * from "./downgrade-requests";
+export * from "./spend-management";
diff --git a/apps/workflows/jobs/spend-management.ts b/apps/workflows/jobs/spend-management.ts
new file mode 100644
index 0000000000..b563c67c40
--- /dev/null
+++ b/apps/workflows/jobs/spend-management.ts
@@ -0,0 +1,281 @@
+import { getClerkOrganizationsAdmins } from "@/lib/clerk";
+import { type Budget, connectDatabase, inArray, schema } from "@/lib/db";
+import { env } from "@/lib/env";
+import { Tinybird } from "@/lib/tinybird";
+import { chunkArray } from "@/lib/utils";
+import { client } from "@/trigger";
+import { cronTrigger } from "@trigger.dev/sdk";
+import { getCurrentUsageBill } from "@unkey/billing";
+import { Resend } from "@unkey/resend";
+
+client.defineJob({
+  id: "billing.budgets.usage-reached",
+  name: "Spend Management",
+  version: "0.0.1",
+  trigger: cronTrigger({
+    cron: "*/10 * * * *",
+  }),
+  run: async (_payload, io, _ctx) => {
+    const db = connectDatabase();
+    const tinybird = new Tinybird(env().TINYBIRD_TOKEN);
+    const resend = new Resend({ apiKey: env().RESEND_API_KEY });
+
+    let workspaces = await io.runTask("list workspaces", async () =>
+      db.query.workspaces.findMany({
+        where: (table, { isNotNull, isNull, not, eq, and }) =>
+          and(
+            isNotNull(table.stripeCustomerId),
+            isNotNull(table.subscriptions),
+            not(eq(table.plan, "free")),
+            isNull(table.deletedAt),
+          ),
+        with: {
+          budgets: true,
+        },
+      }),
+    );
+
+    workspaces = workspaces.filter(
+      (ws) =>
+        ws.subscriptions &&
+        Object.keys(ws.subscriptions).length > 0 &&
+        ws.budgets.filter(isActiveBudget).length > 0,
+    );
+
+    await io.logger.info(`found ${workspaces.length} workspaces`, workspaces);
+
+    const t = new Date();
+    t.setUTCMonth(t.getUTCMonth() - 1);
+    const year = t.getUTCFullYear();
+    const month = t.getUTCMonth() + 1; // months are 0 indexed
+
+    // TODO: Find a way to pipe Tinybird for a given set of workspaceIds.
+    const activeKeys = await io.runTask("list involved workspaces active keys", async () =>
+      Promise.all(
+        workspaces.map(async (workspace) =>
+          tinybird
+            .activeKeys({
+              workspaceId: workspace.id,
+              year,
+              month,
+            })
+            .then((res) => ({
+              activeKeys: res.data.at(0)?.keys ?? 0,
+              workspaceId: workspace.id,
+            })),
+        ),
+      ),
+    );
+    // TODO: Find a way to pipe Tinybird for a given set of workspaceIds.
+    const verifications = await io.runTask("list involved workspaces key verifications", async () =>
+      Promise.all(
+        workspaces.map(async (workspace) =>
+          tinybird
+            .verifications({
+              workspaceId: workspace.id,
+              year,
+              month,
+            })
+            .then((res) => ({
+              verifications: res.data.at(0)?.success ?? 0,
+              workspaceId: workspace.id,
+            })),
+        ),
+      ),
+    );
+    // TODO: Find a way to pipe Tinybird for a given set of workspaceIds.
+    const ratelimits = await io.runTask("list involved workspaces ratelimits", async () =>
+      Promise.all(
+        workspaces.map(async (workspace) =>
+          tinybird
+            .ratelimits({
+              workspaceId: workspace.id,
+              year,
+              month,
+            })
+            .then((res) => ({
+              ratelimits: res.data.at(0)?.success ?? 0,
+              workspaceId: workspace.id,
+            })),
+        ),
+      ),
+    );
+
+    await io.logger.info("estimate workspaces current billing");
+    const currentUsages = workspaces.map((workspace) => {
+      const usedActiveKeys =
+        activeKeys.find((usage) => usage.workspaceId === workspace.id)?.activeKeys || 0;
+      const usedVerifications =
+        verifications.find((usage) => usage.workspaceId === workspace.id)?.verifications || 0;
+      const usedRatelimits =
+        ratelimits.find((usage) => usage.workspaceId === workspace.id)?.ratelimits || 0;
+
+      const { currentPrice, error } = getCurrentUsageBill(
+        {
+          activeKeys: usedActiveKeys,
+          verifications: usedVerifications,
+          ratelimits: usedRatelimits,
+        },
+        workspace.subscriptions,
+      );
+
+      if (error) {
+        io.logger.error(error, { workspaceId: workspace.id });
+        throw new Error("getCurrentUsageBill failed");
+      }
+
+      return {
+        currentPrice,
+        workspaceId: workspace.id,
+      };
+    });
+
+    await io.logger.info("list workspaces that exceeded their budgeted usage");
+    const exceededBudgetedAmount: {
+      budgetId: string;
+      emails: string[];
+      tenantId: string;
+      workspaceId: string;
+      workspaceName: string;
+      budgetedAmount: number;
+      currentPeriodBilling: number;
+    }[] = [];
+    workspaces.forEach((workspace) => {
+      const currentPrice = currentUsages.find(
+        (usage) => usage.workspaceId === workspace.id,
+      )?.currentPrice;
+
+      if (!currentPrice) {
+        return null;
+      }
+
+      const workspaceExceededBudgets = workspace.budgets
+        .filter(
+          // Checks if current price exceeds the greatest budgeted amount
+          (budget) => isActiveBudget(budget) && currentPrice > budget.fixedAmount,
+        )
+        .map((budget) => ({
+          budgetId: budget.id,
+          emails: budget.data.additionalEmails ?? [],
+          tenantId: workspace.tenantId,
+          workspaceId: workspace.id,
+          workspaceName: workspace.name,
+          budgetedAmount: budget.fixedAmount,
+          currentPeriodBilling: currentPrice,
+        }));
+
+      exceededBudgetedAmount.push(...workspaceExceededBudgets);
+    });
+
+    if (exceededBudgetedAmount.length === 0) {
+      await io.logger.info("no budgets found with exceeded usage.");
+
+      return;
+    }
+
+    // TODO: Assumming admin users will not change frequently their emails, we could store in in the budget entity to avoid this step.
+    await io.runTask(
+      "retrieve workpaces admin emails from Clerk for exceeded budgets",
+      async () => {
+        const uniqueTenantsIds = exceededBudgetedAmount.reduce<string[]>((acc, { tenantId }) => {
+          if (!acc.includes(tenantId)) {
+            acc.push(tenantId);
+          }
+
+          return acc;
+        }, []);
+
+        const admins = await getClerkOrganizationsAdmins(uniqueTenantsIds);
+
+        for (let i = 0; i < exceededBudgetedAmount.length; i++) {
+          const foundAdmin = admins.find(
+            (admin) => admin.tenantId === exceededBudgetedAmount[i].tenantId,
+          );
+          if (foundAdmin) {
+            exceededBudgetedAmount[i].emails.unshift(foundAdmin.email);
+          } else {
+            io.logger.warn("Admin email not found", {
+              tenantId: exceededBudgetedAmount[i].tenantId,
+              workspaceId: exceededBudgetedAmount[i].workspaceId,
+            });
+          }
+        }
+      },
+    );
+
+    await io.logger.info(
+      `sending budget exceeded email to ${exceededBudgetedAmount.length} workspaces`,
+      { exceededBudgetedAmount },
+    );
+
+    const notifiedBudgetIds = await io.runTask(
+      "sending budget exceeded email to involved workspaces",
+      async () => {
+        const _notifiedBudgetIds = [];
+
+        // Whenever we failed to find the Admin email and no additional emails were set.
+        const filteredExceededBudgetedAmount = exceededBudgetedAmount.filter(
+          (budget) => budget.emails.length > 0,
+        );
+        const batches = chunkArray(filteredExceededBudgetedAmount, 100);
+
+        for await (const batch of batches) {
+          io.logger.info(`batch sending budget exceeded email to ${batch.length} workspaces`);
+
+          const { success, error } = await resend.sendBatchBudgetExceeded(
+            batch.map((budget) => ({
+              ...budget,
+              email: budget.emails[0], /// @dev `budget.emails` always have at least 1 element.
+              ccEmails: budget.emails.slice(1),
+            })),
+          );
+
+          if (success) {
+            _notifiedBudgetIds.push(...batch.map((budget) => budget.budgetId));
+          } else {
+            io.logger.error("failed to batch send budget exceeded email", {
+              budgetIds: batch.map((budget) => budget.budgetId),
+              error,
+            });
+          }
+        }
+
+        return _notifiedBudgetIds;
+      },
+    );
+
+    if (notifiedBudgetIds.length > 0) {
+      await io.runTask(
+        `updating ${notifiedBudgetIds.length} notified budgets in database`,
+        async () => {
+          await db
+            .update(schema.budgets)
+            .set({ lastReachedAt: new Date() })
+            .where(inArray(schema.budgets.id, notifiedBudgetIds));
+        },
+      );
+    }
+
+    return {
+      notifiedBudgetIds,
+    };
+  },
+});
+
+/**
+ * Determines if a budget is currently enabled and has not reached its limit this month.
+ * This implies the budget has not been notified for the current month.
+ */
+function isActiveBudget(budget: Budget) {
+  const currentDate = new Date();
+  const currentMonth = currentDate.getUTCMonth();
+  const currentYear = currentDate.getUTCFullYear();
+
+  const lastReachedDate = budget.lastReachedAt ? new Date(budget.lastReachedAt) : null;
+  const isSameMonthAndYear =
+    lastReachedDate &&
+    lastReachedDate.getUTCMonth() === currentMonth &&
+    lastReachedDate.getUTCFullYear() === currentYear;
+
+  return budget.enabled && !isSameMonthAndYear;
+}
diff --git a/apps/workflows/lib/clerk.ts b/apps/workflows/lib/clerk.ts
new file mode 100644
index 0000000000..336e9314c2
--- /dev/null
+++ b/apps/workflows/lib/clerk.ts
@@ -0,0 +1,101 @@
+import { clerkClient } from "@clerk/nextjs";
+import { chunkArray } from "./utils";
+
+type ClerkUserData = { id: string; name: string; email: string; tenantId: string };
+
+export async function getClerkOrganizationUsers(tenantId: string): Promise<ClerkUserData[]> {
+  const userIds: string[] = [];
+  if (tenantId.startsWith("org_")) {
+    const members = await clerkClient.organizations.getOrganizationMembershipList({
+      organizationId: tenantId,
+    });
+    for (const m of members) {
+      userIds.push(m.publicUserData!.userId);
+    }
+  } else {
+    userIds.push(tenantId);
+  }
+
+  return await fetchUserDetails(userIds.map((id) => ({ id, tenantId })));
+}
+
+export async function getClerkOrganizationsAdmins(tenantIds: string[]): Promise<ClerkUserData[]> {
+  const userIds: { id: string; tenantId: string }[] = [];
+  const organizationIds: string[] = [];
+
+  tenantIds.forEach((tenantId) => {
+    if (tenantId.startsWith("org_")) {
+      organizationIds.push(tenantId);
+    } else {
+      userIds.push({ id: tenantId, tenantId });
+    }
+  });
+
+  const adminUserIdsFromOrgs = await fetchAdminUserIdsFromOrganizations(organizationIds);
+  userIds.push(...adminUserIdsFromOrgs);
+
+  return await fetchUserDetails(userIds);
+}
+
+async function fetchUserDetails(
+  userTenantPairs: { id: string; tenantId: string }[],
+): Promise<ClerkUserData[]> {
+  const userBatches = chunkArray(userTenantPairs, 90);
+  const users: ClerkUserData[] = [];
+
+  for await (const batch of userBatches) {
+    const details = await Promise.all(
+      batch.map(async (userTenantPair) => {
+        const user = await clerkClient.users.getUser(userTenantPair.id);
+
+        const email = user.emailAddresses.at(0)?.emailAddress;
+
+        if (!email) {
+          throw new Error(`user ${user.id} does not have an email`);
+        }
+
+        return {
+          id: user.id,
+          name: user.firstName ?? user.username ?? "there",
+          email,
+          tenantId: userTenantPair.tenantId,
+        };
+      }),
+    );
+
+    users.push(...details);
+  }
+
+  return users;
+}
+
+async function fetchAdminUserIdsFromOrganizations(
+  organizationIds: string[],
+): Promise<{ id: string; tenantId: string }[]> {
+  /// @dev Clerk BE rate limit is 100 requests per 10 seconds.
+  const orgBatches = chunkArray(organizationIds, 90);
+  const adminUserIds: { id: string; tenantId: string }[] = [];
+
+  for await (const batch of orgBatches) {
+    const batchAdminUserIds = await Promise.all(
+      batch.map(async (orgId) => {
+        const members = await clerkClient.organizations.getOrganizationMembershipList({
+          organizationId: orgId,
+        });
+        /// @dev This only takes the first admin of the organization.
+        const adminUserId = members.find((m) => m.role === "admin" || m.role === "org:admin")
+          ?.publicUserData?.userId;
+
+        if (!adminUserId) {
+          return null;
+        }
+
+        return { id: adminUserId, tenantId: orgId };
+      }),
+    );
+
+    adminUserIds.push(...(batchAdminUserIds.filter(Boolean) as { id: string; tenantId: string }[]));
+  }
+
+  return adminUserIds;
+}
diff --git a/apps/workflows/lib/utils.ts b/apps/workflows/lib/utils.ts
new file mode 100644
index 0000000000..b89eb5ad57
--- /dev/null
+++ b/apps/workflows/lib/utils.ts
@@ -0,0 +1,8 @@
+export function chunkArray<T>(array: T[], chunkSize: number): T[][] {
+  const result: T[][] = [];
+  for (let i = 0; i < array.length; i += chunkSize) {
+    const chunk = array.slice(i, i + chunkSize);
+    result.push(chunk);
+  }
+  return result;
+}
diff --git a/internal/billing/src/index.ts b/internal/billing/src/index.ts
index 36d25dc16a..9d3a10a371 100644
--- a/internal/billing/src/index.ts
+++ b/internal/billing/src/index.ts
@@ -1,3 +1,4 @@
 export * from "./quota";
 export * from "./tiers";
+export * from "./usage";
 export * from "./subscriptions";
diff --git a/internal/billing/src/usage.ts b/internal/billing/src/usage.ts
new file mode 100644
index 0000000000..6b325d4c0b
--- /dev/null
+++ b/internal/billing/src/usage.ts
@@ -0,0 +1,91 @@
+import type { FixedSubscription, TieredSubscription } from "./subscriptions";
+import { calculateTieredPrices } from "./tiers";
+
+export function forecastUsage(currentUsage: number): number {
+  const t = new Date();
+  t.setUTCDate(1);
+  t.setUTCHours(0, 0, 0, 0);
+
+  const start = t.getTime();
+  t.setUTCMonth(t.getUTCMonth() + 1);
+  const end = t.getTime() - 1;
+
+  const passed = (Date.now() - start) / (end - start);
+
+  return currentUsage * (1 + 1 / passed);
+}
+
+type WorkspaceSubscriptions = {
+  plan?: FixedSubscription;
+  support?: FixedSubscription;
+  activeKeys?: TieredSubscription;
+  verifications?: TieredSubscription;
+  ratelimits?: TieredSubscription;
+};
+type WorkspaceUsages = {
+  activeKeys: number;
+  verifications: number;
+  ratelimits: number;
+};
+
+export function getCurrentUsageBill(
+  usage: WorkspaceUsages,
+  workspaceSubscriptions?: WorkspaceSubscriptions | null,
+) {
+  let currentPrice = 0;
+  let estimatedTotalPrice = 0;
+
+  if (workspaceSubscriptions?.plan) {
+    const cost = Number.parseFloat(workspaceSubscriptions.plan.cents);
+    currentPrice += cost;
+    estimatedTotalPrice += cost; // does not scale
+  }
+
+  if (workspaceSubscriptions?.support) {
+    const cost = Number.parseFloat(workspaceSubscriptions.support.cents);
+    currentPrice += cost;
+    estimatedTotalPrice += cost; // does not scale
+  }
+
+  if (workspaceSubscriptions?.activeKeys) {
+    const cost = calculateTieredPrices(workspaceSubscriptions.activeKeys.tiers, usage.activeKeys);
+    if (cost.err) {
+      return {
+        error: cost.err.message,
+        currentPrice: 0,
+        estimatedTotalPrice: 0,
+      };
+    }
+    currentPrice += cost.val.totalCentsEstimate;
+  }
+
+  if (workspaceSubscriptions?.verifications) {
+    const cost = calculateTieredPrices(
+      workspaceSubscriptions.verifications.tiers,
+      usage.verifications,
+    );
+    if (cost.err) {
+      return {
+        error: cost.err.message,
+        currentPrice: 0,
+        estimatedTotalPrice: 0,
+      };
+    }
+    currentPrice += cost.val.totalCentsEstimate;
+    estimatedTotalPrice += forecastUsage(cost.val.totalCentsEstimate);
+  }
+
+  if (workspaceSubscriptions?.ratelimits) {
+    const cost = calculateTieredPrices(workspaceSubscriptions.ratelimits.tiers, usage.ratelimits);
+    if (cost.err) {
+      return {
+        error: cost.err.message,
+        currentPrice: 0,
+        estimatedTotalPrice: 0,
+      };
+    }
+    currentPrice += cost.val.totalCentsEstimate;
+  }
+
+  return { currentPrice, estimatedTotalPrice, error: null };
+}
diff --git a/internal/db/src/schema/budgets.ts b/internal/db/src/schema/budgets.ts
new file mode 100644
index 0000000000..cf4dd9a8a3
--- /dev/null
+++ b/internal/db/src/schema/budgets.ts
@@ -0,0 +1,56 @@
+import { relations } from "drizzle-orm";
+import {
+  boolean,
+  datetime,
+  float,
+  index,
+  json,
+  mysqlEnum,
+  mysqlTable,
+  varchar,
+} from "drizzle-orm/mysql-core";
+import { workspaces } from "./workspaces";
+
+export const budgets = mysqlTable(
+  "budgets",
+  {
+    id: varchar("id", { length: 256 }).primaryKey(),
+    workspaceId: varchar("workspace_id", { length: 256 })
+      .notNull()
+      .references(() => workspaces.id, { onDelete: "cascade" }),
+    name: varchar("name", { length: 256 }),
+    type: mysqlEnum("type", ["soft", "hard"]).notNull(),
+    /**
+     * Sets if the budget is enabled or not.
+     */
+    enabled: boolean("enabled").default(true).notNull(),
+    fixedAmount: float("fixed_amount").notNull(),
+    data: json("data")
+      .$type<{
+        /**
+         * Additional emails to notify.
+         */
+        additionalEmails?: string[];
+
+        /**
+         * Webhook URL to POST trigger when metered resources reached set amount.
+         * @dev TODO: Not used currently.
+         */
+        webhookUrl?: string;
+      }>()
+      .notNull(),
+    lastReachedAt: datetime("last_reached_at", { mode: "date", fsp: 3 }),
+    createdAt: datetime("created_at", { mode: "date", fsp: 3 }),
+  },
+  (table) => ({
+    workspaceId: index("workspace_id_idx").on(table.workspaceId),
+    // TODO: Should index by `enabled`?
+  }),
+);
+
+export const budgetsRelations = relations(budgets, ({ one }) => ({
+  workspace: one(workspaces, {
+    fields: [budgets.workspaceId],
+    references: [workspaces.id],
+  }),
+}));
diff --git a/internal/db/src/schema/index.ts b/internal/db/src/schema/index.ts
index 828814f24c..1aba52a643 100644
--- a/internal/db/src/schema/index.ts
+++ b/internal/db/src/schema/index.ts
@@ -1,4 +1,5 @@
 export * from "./apis";
+export * from "./budgets";
 export * from "./rbac";
 export * from "./keyAuth";
 export * from "./keys";
diff --git a/internal/db/src/schema/workspaces.ts b/internal/db/src/schema/workspaces.ts
index e7c11207c5..ef8863df3c 100644
--- a/internal/db/src/schema/workspaces.ts
+++ b/internal/db/src/schema/workspaces.ts
@@ -10,6 +10,7 @@ import {
   varchar,
 } from "drizzle-orm/mysql-core";
 import { apis } from "./apis";
+import { budgets } from "./budgets";
 import { gateways } from "./gateway";
 import { keys } from "./keys";
 import { ratelimitNamespaces } from "./ratelimit";
@@ -109,6 +110,7 @@ export const workspaces = mysqlTable(
 
 export const workspacesRelations = relations(workspaces, ({ many }) => ({
   apis: many(apis),
+  budgets: many(budgets),
   keys: many(keys, {
     relationName: "workspace_key_relation",
   }),
diff --git a/internal/db/src/types.ts b/internal/db/src/types.ts
index 14c99348d5..2bdc194f28 100644
--- a/internal/db/src/types.ts
+++ b/internal/db/src/types.ts
@@ -3,6 +3,7 @@ import type * as schema from "./schema";
 
 export type Key = InferSelectModel<typeof schema.keys>;
 export type Api = InferSelectModel<typeof schema.apis>;
+export type Budget = InferSelectModel<typeof schema.budgets>;
 export type Workspace = InferSelectModel<typeof schema.workspaces>;
 export type KeyAuth = InferSelectModel<typeof schema.keyAuth>;
 export type VercelIntegration = InferSelectModel<typeof schema.vercelIntegrations>;
diff --git a/internal/id/src/generate.ts b/internal/id/src/generate.ts
index c508941c04..08ecb61b80 100644
--- a/internal/id/src/generate.ts
+++ b/internal/id/src/generate.ts
@@ -16,6 +16,7 @@ const prefixes = {
   ratelimitNamespace: "rlns",
   ratelimitOverride: "rlor",
   permission: "perm",
+  budget: "bud",
   secret: "sec",
   headerRewrite: "hrw",
   gateway: "gw",
diff --git a/internal/resend/emails/usage-budget-exceeded.tsx b/internal/resend/emails/usage-budget-exceeded.tsx
new file mode 100644
index 0000000000..7ff873ea70
--- /dev/null
+++ b/internal/resend/emails/usage-budget-exceeded.tsx
@@ -0,0 +1,75 @@
+import { Container } from "@react-email/container";
+import { Head } from "@react-email/head";
+import { Heading } from "@react-email/heading";
+import { Hr } from "@react-email/hr";
+import { Html } from "@react-email/html";
+import { Link } from "@react-email/link";
+import { Section } from "@react-email/section";
+import { Tailwind } from "@react-email/tailwind";
+import { Text } from "@react-email/text";
+import React from "react";
+import tailwindConfig from "../tailwind.config";
+
+export type Props = {
+  workspace: string;
+  budgetedAmount: number;
+  currentPeriodBilling: number;
+};
+
+function UsageBudgetExceeded({ workspace, budgetedAmount, currentPeriodBilling }: Props) {
+  return (
+    <Tailwind config={tailwindConfig}>
+      <Html className="font-sans text-zinc-800">
+        <Head />
+        <Section className="bg-white">
+          <Container className="container mx-auto">
+            <Heading className="font-sans text-2xl text-semibold">Budget Notification</Heading>
+            <Text>Hey,</Text>
+            <Text>
+              Hope you're doing awesome! Just a quick heads up from your friends at Unkey — looks
+              like your spending has just nudged past your set budget.
+            </Text>
+
+            <Text className="mb-1">
+              <b>Workspace: </b>
+              {workspace}
+            </Text>
+            <Text className="my-1">
+              <b>Your Budget: </b>${budgetedAmount}
+            </Text>
+            <Text className="my-1">
+              <b>Current Spend: </b>${currentPeriodBilling}
+            </Text>
+            <Text className="mt-1">
+              <b>Over by: </b>${currentPeriodBilling - budgetedAmount}
+            </Text>
+
+            <Text>
+              {"You can find further details by accessing your "}
+              <Link href="https://unkey.dev/app/settings/billing">Unkey Billing dashboard</Link>.
+            </Text>
+
+            <Text>
+              Cheers,
+              <br />
+              Andreas
+            </Text>
+
+            <Hr />
+            <Text>
+              {"P.S. Love seeing how you’re using Unkey. Let’s keep the good vibes rolling!"}
+            </Text>
+          </Container>
+        </Section>
+      </Html>
+    </Tailwind>
+  );
+}
+
+UsageBudgetExceeded.PreviewProps = {
+  workspace: "Mugiwara Crew",
+  budgetedAmount: 100,
+  currentPeriodBilling: 115,
+} satisfies Props;
+
+export default UsageBudgetExceeded;
diff --git a/internal/resend/src/client.tsx b/internal/resend/src/client.tsx
index 27a1eccca4..6a62db9a91 100644
--- a/internal/resend/src/client.tsx
+++ b/internal/resend/src/client.tsx
@@ -5,7 +5,9 @@ import React from "react";
 import { PaymentIssue } from "../emails/payment_issue";
 import { SubscriptionEnded } from "../emails/subscription_ended";
 import { TrialEnded } from "../emails/trial_ended";
+import UsageBudgetExceeded from "../emails/usage-budget-exceeded";
 import { WelcomeEmail } from "../emails/welcome_email";
+
 export class Resend {
   public readonly client: Client;
   private readonly replyTo = "support@unkey.dev";
@@ -101,4 +103,57 @@ export class Resend {
       console.error("Error occurred sending payment issue email ", JSON.stringify(error));
     }
   }
+
+  public async sendBatchBudgetExceeded(
+    batch: {
+      email: string;
+      ccEmails: string[];
+      workspaceName: string;
+      budgetedAmount: number;
+      currentPeriodBilling: number;
+    }[],
+  ): Promise<{ success: true; error?: null } | { success: false; error: string }> {
+    try {
+      if (batch.length > 100) {
+        throw new Error("Allowed up to 100 batch emails.");
+      }
+
+      const result = await this.client.batch.send(
+        batch.map((data) => {
+          const html = render(
+            <UsageBudgetExceeded
+              workspace={data.workspaceName}
+              budgetedAmount={data.budgetedAmount}
+              currentPeriodBilling={data.currentPeriodBilling}
+            />,
+          );
+
+          return {
+            to: data.email,
+            cc: data.ccEmails,
+            from: "james@updates.appdoc.io",
+            reply_to: this.replyTo,
+            subject: "Budget Notification Usage Exceeded",
+            html,
+          };
+        }),
+      );
+
+      if (!result.error) {
+        return { success: true };
+      }
+
+      console.error(
+        "Error occurred batch sending budget exceeded email ",
+        JSON.stringify(result.error),
+      );
+      return { success: false, error: result.error.message };
+    } catch (error) {
+      console.error(
+        "Error occurred batch sending budget exceeded email ",
+        (error as Error).message,
+      );
+      return { success: false, error: (error as Error).message };
+    }
+  }
 }
diff --git a/internal/tinybird/.gitignore b/internal/tinybird/.gitignore
new file mode 100644
index 0000000000..77f27a5932
--- /dev/null
+++ b/internal/tinybird/.gitignore
@@ -0,0 +1,2 @@
+.tinyb
+.venv
\ No newline at end of file