Blob

npm install @edgeone/pages-blob

import { getStore } from "@edgeone/pages-blob";

export async function onRequest({ request }) {
  const store = getStore("my-store");

  // 写入
  await store.set("hello.txt", "Hello, EdgeOne Pages!");

  const content = await store.get("hello.txt");

  return new Response(content);
}

import { getStore, listStores } from "@edgeone/pages-blob";

const store = getStore("my-store");

// 也可使用对象形式，便于同时指定默认一致性
const store = getStore({ name: "my-store", consistency: "strong" });

const store = getStore({
  name: "my-store",
  projectId: "pages-urtsvuwmfvli",
  token: "your-api-token",
});

await store.set("photos/cat.jpg", imageBuffer);
await store.set("notes/todo.txt", "Buy milk");

// 防覆盖：仅在 Key 不存在时写入
await store.set("init.json", data, { onlyIfNew: true });

await store.setJSON("user/preferences", { theme: "dark", lang: "zh-CN" });

const text = await store.get("hello.txt");
const json = await store.get("config.json", { type: "json" });
const buffer = await store.get("image.png", { type: "arrayBuffer" });
const blob = await store.get("video.mp4", { type: "blob" });
const stream = await store.get("large-file.zip", { type: "stream" });

// 强一致性读取
const fresh = await store.get("counter", { consistency: "strong" });

const result = await store.getWithHeaders("document.pdf");
// result.body — 对象内容
// result.headers — 完整响应头（content-type, etag, cache-control 等）

Promise<{
  body: string;
  headers: Record<string, string>;
} | null>

await store.delete("photos/cat.jpg");

// 列出所有对象
const { blobs } = await store.list();

// 按前缀过滤
const { blobs } = await store.list({ prefix: "photos/" });

// 按目录分组（只返回当前层级的文件和子目录）
const { blobs, directories } = await store.list({
  prefix: "photos/",
  directories: true,
});

// 强一致性
const { blobs } = await store.list({ consistency: "strong" });

// 手动分页
const page1 = await store.list({ paginate: false });
const page2 = await store.list({ paginate: false, cursor: page1.cursor });

{
  blobs: Array<{ key: string; etag: string }>;
  directories?: string[];  // 仅 directories: true 时返回
  cursor?: string;         // 仅 paginate: false 时返回
}

const store = getStore("user-uploads");

const { url, key, expiresAt } = await store.createUploadUrl("files/photo.jpg");

{
  url: string;        // 预签名 URL
  key: string;        // 对象 Key
  expiresAt: number;  // 过期时间（Unix 时间戳，单位秒）
}

import { listStores } from "@edgeone/pages-blob";

// 在 Pages Functions 中
const { stores } = await listStores();

// 外部访问
const { stores } = await listStores({
  projectId: "pages-urtsvuwmfvli",
  token: "your-api-token",
});

{
  stores: Array<{ name: string }>;
}

// 函数端：签发一次性上传 URL
import { getStore } from "@edgeone/pages-blob";

export async function onRequest({ request }) {
  if (request.method !== "POST") {
    return new Response("Method not allowed", { status: 405 });
  }

  const { name, contentType } = await request.json();
  const store = getStore("user-uploads");

  const { url, key, expiresAt } = await store.createUploadUrl(
    `uploads/${Date.now()}-${name}`,
    {
      expireSeconds: 3600,
      contentType: contentType || "application/octet-stream",
    }
  );

  return new Response(JSON.stringify({ url, key, expiresAt }), {
    headers: { "Content-Type": "application/json" },
  });
}

// 浏览器端：取到 URL 后直接 PUT，无需 SDK
async function uploadFile(file) {
  // 1. 向函数申请上传 URL
  const { url, key } = await fetch("/api/get-upload-url", {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ name: file.name, contentType: file.type }),
  }).then((r) => r.json());

  // 2. 直接上传到 Blob
  await fetch(url, {
    method: "PUT",
    body: file,
    headers: { "Content-Type": file.type },
  });

  return key;
}

import { getStore } from "@edgeone/pages-blob";

export async function onRequest({ request }) {
  const store = getStore("user-uploads");
  const url = new URL(request.url);
  const prefix = url.searchParams.get("path") || "";

  const { blobs, directories } = await store.list({
    prefix,
    directories: true,
  });

  return new Response(
    JSON.stringify({ files: blobs, folders: directories }),
    { headers: { "Content-Type": "application/json" } }
  );
}

import { getStore } from "@edgeone/pages-blob";

export async function onRequest({ request }) {
  const store = getStore("configs");

  // 仅在 Key 不存在时写入，避免覆盖已有数据
  await store.setJSON("app/settings", { version: 1 }, { onlyIfNew: true });

  const settings = await store.get("app/settings", { type: "json" });
  return new Response(JSON.stringify(settings), {
    headers: { "Content-Type": "application/json" },
  });
}