Purge selektif dengan Cache Tag

Purge Everything pada portal dengan 500 ribu request per jam berarti mengirim seluruh trafik itu ke origin sekaligus. Purge by tag menghindarinya sepenuhnya.

Memberi label

// Di halaman artikel
Astro.response.headers.set(
  "Cache-Tag",
  [
    `artikel-${artikel.id}`,
    `kategori-${artikel.kategoriSlug}`,
    `penulis-${artikel.penulisId}`,
    "tipe-artikel",
  ].join(","),
);

// Di halaman kategori — tag yang beririsan, disengaja
Astro.response.headers.set(
  "Cache-Tag",
  [`kategori-${slug}`, "tipe-daftar", "beranda-terkait"].join(","),
);

Irisan tag inilah yang membuat sistemnya bekerja. Saat artikel disunting, purge artikel-4471 membersihkan halaman artikelnya; purge kategori-ekonomi sekaligus membersihkan halaman kategori dan beranda yang menampilkannya.

Memanggil purge

// src/lib/purge.ts
import { env } from "./env";

export async function purgeTag(tag: string[]): Promise<boolean> {
  if (tag.length === 0) return true;

  // Maksimum 100 tag per permintaan.
  const potongan: string[][] = [];
  for (let i = 0; i < tag.length; i += 100) potongan.push(tag.slice(i, i + 100));

  for (const p of potongan) {
    try {
      const res = await fetch(
        `https://api.cloudflare.com/client/v4/zones/${env.CF_ZONE_ID}/purge_cache`,
        {
          method: "POST",
          signal: AbortSignal.timeout(8000),
          headers: {
            Authorization: `Bearer ${env.CF_API_TOKEN}`,
            "Content-Type": "application/json",
          },
          body: JSON.stringify({ tags: p }),
        },
      );

      if (!res.ok) {
        console.error(JSON.stringify({
          level: "error", pesan: "purge gagal", status: res.status, tag: p,
        }));
        return false;
      }
    } catch (e) {
      console.error(JSON.stringify({ level: "error", pesan: "purge error", e: String(e) }));
      return false;
    }
  }
  return true;
}

Memanggilnya di tempat yang benar

export const terbitkanArtikel = defineAction({
  input: z.object({ id: z.number().int().positive() }),
  handler: async ({ id }, ctx) => {
    if (!boleh(ctx.locals.member?.peran, "artikel:terbitkan")) {
      throw new ActionError({ code: "FORBIDDEN" });
    }

    // 1. Transaksi database dulu, dan selesai.
    const artikel = await dbTulis.transaction().execute(async (trx) => {
      await trx.updateTable("artikel")
        .set({ status: "terbit", terbit_pada: new Date() })
        .where("id", "=", id).where("status", "=", "tinjau")
        .executeTakeFirstOrThrow();

      return trx.selectFrom("artikel")
        .select(["id", "kategori_id", "penulis_id"])
        .where("id", "=", id)
        .executeTakeFirstOrThrow();
    });

    // 2. Purge SETELAH commit.
    await purgeTag([
      `artikel-${artikel.id}`,
      `kategori-${await slugKategori(artikel.kategori_id)}`,
      `penulis-${artikel.penulis_id}`,
      "beranda",
    ]);

    return { ok: true };
  },
});

Peta tag untuk portalmu

Kenapa Purge Everything berbahaya di trafikmu

Sebelum purge : 93% dilayani edge, ~21 req/detik ke origin
Purge Everything
Sesudah purge : 0% dilayani edge,  ~347 req/detik ke origin

Origin-mu menerima 16 kali lipat beban normalnya, seketika, sampai
cache terisi kembali. Autoscaling butuh menit untuk bereaksi.
Yang terjadi lebih dulu adalah pool database habis.

Purge by prefix

await fetch(`https://api.cloudflare.com/client/v4/zones/${env.CF_ZONE_ID}/purge_cache`, {
  method: "POST",
  headers: { Authorization: `Bearer ${env.CF_API_TOKEN}`, "Content-Type": "application/json" },
  body: JSON.stringify({
    prefixes: ["portal.contoh.id/berita/ekonomi/"],
  }),
});

Berguna untuk perubahan yang menyentuh seluruh cabang URL — misalnya struktur kategori berubah. Batasnya 100 prefix per permintaan.

Kalau purge gagal

Untuk portal berita, pilihan kedua hampir selalu tepat: kegagalan purge berarti pembaca melihat versi lama selama beberapa menit, sementara menggagalkan penerbitan berarti redaksi terhambat. Pasang alarm kalau tingkat kegagalan purge naik.