MediaStore¶

Storage abstraction for binary media content.

Interface¶

class MediaStore:
    async def upload(self, data: bytes, filename: str, mime_type: str) -> str: ...
    async def fetch(self, uri: str) -> tuple[bytes, str]: ...
    async def exists(self, uri: str) -> bool: ...

interface MediaStore {
  upload(data: Buffer, filename: string, mimeType: string): Promise<string>;
  fetch(uri: string): Promise<{ data: Buffer; mimeType: string }>;
  exists(uri: string): Promise<boolean>;
}

public interface MediaStore {
    String upload(byte[] data, String filename, String mimeType);
    MediaFetchResult fetch(String uri);
    boolean exists(String uri);
}

public record MediaFetchResult(byte[] data, String mimeType) {}

Implementations¶

LocalMediaStore¶

Default backend. Stores files on the local filesystem.

URI format: file:///path/to/file

S3MediaStore¶

Production backend for S3-compatible storage (AWS S3, MinIO).

URI format: s3://bucket/prefix/filename

Fail-fast. There is no default bucket. When MCP_MESH_MEDIA_STORAGE=s3, construction fails fast: a missing boto3 raises RuntimeError, and an unset MCP_MESH_MEDIA_STORAGE_BUCKET raises ValueError. Set MCP_MESH_MEDIA_STORAGE_VALIDATE=true to also probe credentials and bucket reachability (opt-in head_bucket) before serving traffic.

Factory¶

from _mcp_mesh.media.media_store import get_media_store

store = get_media_store()  # singleton based on MCP_MESH_MEDIA_STORAGE

import { getMediaStore } from "@mcpmesh/sdk";

const store = getMediaStore();

@Autowired
private MediaStore mediaStore;  // auto-configured bean

Backend selected by MCP_MESH_MEDIA_STORAGE environment variable (local or s3).

See Also¶

• MediaStore Configuration -- Full setup guide
• Environment Variables -- All config options