Connect with the S3 API

S3_ENDPOINT=https://<account-id>.r2.cloudflarestorage.com
S3_BUCKET=product-images-x7k2m
S3_ACCESS_KEY_ID=<access-key>
S3_SECRET_ACCESS_KEY=<secret-key>

import { createReadStream } from "node:fs";
import { writeFile } from "node:fs/promises";
import {
  S3Client,
  ListObjectsV2Command,
  GetObjectCommand,
  DeleteObjectCommand,
} from "@aws-sdk/client-s3";
import { Upload } from "@aws-sdk/lib-storage";
import { getSignedUrl } from "@aws-sdk/s3-request-presigner";

const s3 = new S3Client({
  region: "auto",
  endpoint: process.env.S3_ENDPOINT,
  credentials: {
    accessKeyId: process.env.S3_ACCESS_KEY_ID,
    secretAccessKey: process.env.S3_SECRET_ACCESS_KEY,
  },
  requestChecksumCalculation: "WHEN_REQUIRED",
  responseChecksumValidation: "WHEN_REQUIRED",
});
const Bucket = process.env.S3_BUCKET;

// Upload a file. Upload splits large files into parts on its own.
await new Upload({
  client: s3,
  params: {
    Bucket,
    Key: "images/logo.png",
    Body: createReadStream("logo.png"),
    ContentType: "image/png",
  },
}).done();

// List the files in a folder.
const { Contents = [] } = await s3.send(
  new ListObjectsV2Command({ Bucket, Prefix: "images/" })
);
for (const object of Contents) {
  console.log(object.Key, object.Size);
}

// Download a file.
const { Body } = await s3.send(
  new GetObjectCommand({ Bucket, Key: "images/logo.png" })
);
await writeFile("logo-copy.png", await Body.transformToByteArray());

// Create a link that works for one hour.
const url = await getSignedUrl(
  s3,
  new GetObjectCommand({ Bucket, Key: "images/logo.png" }),
  { expiresIn: 3600 }
);
console.log(url);

// Delete the file.
await s3.send(new DeleteObjectCommand({ Bucket, Key: "images/logo.png" }));

import os

import boto3
from botocore.config import Config

s3 = boto3.client(
    "s3",
    endpoint_url=os.environ["S3_ENDPOINT"],
    aws_access_key_id=os.environ["S3_ACCESS_KEY_ID"],
    aws_secret_access_key=os.environ["S3_SECRET_ACCESS_KEY"],
    region_name="auto",
    config=Config(signature_version="s3v4"),
)
bucket = os.environ["S3_BUCKET"]

# Upload a file. upload_file splits large files into parts on its own.
s3.upload_file(
    "logo.png", bucket, "images/logo.png", ExtraArgs={"ContentType": "image/png"}
)

# List the files in a folder, page by page.
paginator = s3.get_paginator("list_objects_v2")
for page in paginator.paginate(Bucket=bucket, Prefix="images/"):
    for obj in page.get("Contents", []):
        print(obj["Key"], obj["Size"])

# Download a file.
s3.download_file(bucket, "images/logo.png", "logo-copy.png")

# Create a link that works for one hour.
url = s3.generate_presigned_url(
    "get_object",
    Params={"Bucket": bucket, "Key": "images/logo.png"},
    ExpiresIn=3600,
)
print(url)

# Delete the file.
s3.delete_object(Bucket=bucket, Key="images/logo.png")