Tárolás: R2 objektumtár és KV

6.1R2 = S3, mínusz az egress-számla

Az R2 egy S3-kompatibilis objektumtár, és a legfontosabb tudnivaló üzleti, nem technikai: a kimenő adatforgalom ingyenes. Az S3-nál a tárolásnál gyakran nagyobb tétel a GB-onkénti egress (plusz a CloudFront-forgalom) — az R2-nél tárolásért és műveletekért (Class A/B operations) fizetsz, adatkiadásért soha. Egy médiafájlokat, exportokat, user-uploadokat kiszolgáló SaaS-nál ez tipikusan a legnagyobb egyedi költségcsökkenés az egész migrációban.

Három felületen éred el ugyanazt a bucketet:

A meglévő S3-kódod átállítása jellemzően ennyi: endpoint + credential csere (a region: "auto"):

const S3 = new S3Client({
  region: "auto",
  endpoint: `https://${ACCOUNT_ID}.r2.cloudflarestorage.com`,
  credentials: { accessKeyId, secretAccessKey },   // R2 API token
});
// innentől a PutObjectCommand, GetObjectCommand, multipart… változatlan

6.2R2 a Workerből: binding API és fájlkiszolgálás

{ "r2_buckets": [{ "binding": "UPLOADS", "bucket_name": "app-uploads" }] }

export default defineEventHandler(async (event) => {
  const { env } = event.context.cloudflare;
  const obj = await env.UPLOADS.get(event.context.params.key);
  if (!obj) throw createError({ statusCode: 404 });

  return new Response(obj.body, {        // stream: sosincs egyben a memóriában (2. modul)
    headers: {
      "Content-Type": obj.httpMetadata?.contentType ?? "application/octet-stream",
      "Cache-Control": "public, max-age=31536000",  // a CDN innen cache-eli
      "ETag": obj.httpEtag,
    },
  });
});

Az API a megszokott műveleteket adja (get, put, delete, list, head, multipart), objektumonként httpMetadata (Content-Type, Cache-Control…) és szabad customMetadata mezőkkel. Publikus tartalomhoz nem is kell Worker: a bucket custom domainre köthető, és onnantól a Cloudflare CDN közvetlenül, cache-elve szolgálja ki — ez a „S3 + CloudFront static hosting" egy mozdulatos megfelelője.

6.3Presigned URL-ek: a nagy fájl ne folyjon át a Workeren

A 100 MB-os kérés-limit (2. modul) és a józan ész is azt diktálja, amit S3-nál is csináltál: nagy uploadnál a kliens közvetlenül a tárba töltsön. A minta ugyanaz — a Worker (a könnyű aws4fetch csomaggal vagy S3 SDK-val) aláír egy URL-t, a kliens pedig azt PUT-olja:

import { AwsClient } from "aws4fetch";

const r2 = new AwsClient({ accessKeyId: env.R2_KEY_ID, secretAccessKey: env.R2_SECRET });

const url = new URL(`https://${ACCOUNT_ID}.r2.cloudflarestorage.com/app-uploads/${key}`);
url.searchParams.set("X-Amz-Expires", "3600");

const signed = await r2.sign(new Request(url, { method: "PUT" }),
                            { aws: { signQuery: true } });
return Response.json({ uploadUrl: signed.url });   // a kliens ide PUT-ol

Két hasznos rokon funkció: az object lifecycles (félbehagyott multipart uploadok auto-törlése, lejárati szabályok — az S3 lifecycle rules megfelelője), és az event notifications: a bucket-események (új objektum, törlés) Queues-ba mennek — ez az „S3 event → Lambda" minta megfelelője, és átvezet a következő modulba.

6.4KV: a globális kulcs-érték tár, aminek nincs AWS-párja

A KV-t nehéz egy AWS-termékre képezni: leginkább „ElastiCache + DynamoDB read-heavy fele + SSM Parameter Store" egyben, de globálisan replikálva és a Workerbe drótozva. A modellje: írsz egy kulcsot bárhonnan, és az néhány másodpercen belül a világ minden PoP-jában olvasható — a forró kulcsok a helyi cache-ből ~ezredmásodperc alatt jönnek. Az ára: eventually consistent — egy írás után a világ másik felén rövid ideig (akár ~60 s) még a régi értéket olvashatják, és egy kulcsot érdemes legfeljebb ~1/s gyakorisággal írni.

// feature flag / config — pontosan erre való
const flags = await env.CONFIG.get("feature-flags", { type: "json" });

// cache lejárattal — pl. drága külső API válasza
await env.CACHE.put(`fx:${date}`, JSON.stringify(rates), { expirationTtl: 3600 });

// tenant-routing a multitenant appodhoz: registry-lookup cache-elve (5b!)
const dbId = await env.TENANT_MAP.get(`tenant:${slug}`);

6.5A nagy térkép: hova tegyem az adatot?

Ezzel a modullal együtt már az összes tárolási primitívet ismered — így áll össze a döntési térkép:

6.6Ellenőrizd magad