F-12 Stockage et traitement des médias

Brique F de la plateforme Enterprise AI. Technologie : workers média asynchrones (NATS JetStream), stockage objet compatible S3 (SeaweedFS, Ceph RGW ou cloud) avec SSE-KMS via OpenBao, analyse ClamAV. Version anglaise : ../../en/bricks/F-12-media-processing.md.

Rôle et responsabilités

• Point d'entrée unique de tout média : upload, antivirus, détection MIME, extraction de métadonnées, classification, chiffrement, rétention.
• Cadre de jobs partagé par F-02 à F-11 (file, reprises, progression, annulation).

Position et interactions

• Chemin d'exécution : événement et batch.
• Émet les événements media.uploaded, media.processed, media.deleted ; les politiques de rétention de la brique E s'appliquent.

Part open source et part développée

• Open source réutilisé : SeaweedFS ou S3, ClamAV, NATS JetStream, libmagic, exiftool.
• Développé dans la plateforme : Service média, cadre de jobs, correspondance avec le Multimodal Contract, URL de téléchargement signées.

Modèle de données

Tables du Control Plane (schéma eai) : eai.media, eai.multimodal_jobs, eai.usage_events.

Chaque table de tenant a tenant_id uuid NOT NULL et une politique de sécurité au niveau des lignes sur current_setting('app.tenant_id', true)::uuid. ClickHouse usage_events est la réplique analytique de eai.usage_events (ReplacingMergeTree par event_id).

Contrat : contracts/v1/multimodal-contract.schema.json (schema_version 1.0). L'usage est toujours remonté avec contracts/v1/usage-event.schema.json, l'audit avec contracts/v1/audit-event.schema.json.

Endpoints d'API

Méthode	Chemin
POST	/v1/media
GET	/v1/media/{id}
DELETE	/v1/media/{id}
GET	/v1/multimodal/jobs

POST /v1/media

Requête :

{
  "filename": "invoice-scan.png",
  "mime_type": "image/png",
  "operation": "vision_understanding",
  "classification": "internal",
  "content_base64": "iVBORw0KGgo..."
}

Réponse :

{
  "media_id": "med_01HZX3K9",
  "media_type": "image",
  "mime_type": "image/png",
  "size_bytes": 482113,
  "resolution": "1654x2339",
  "classification": "internal",
  "dlp": {
    "status": "clean",
    "findings": 0
  },
  "storage": {
    "uri": "s3://eai-media/tenant/med_01HZX3K9",
    "encrypted": true
  }
}

GET /v1/media/{id}

Réponse :

{
  "media_id": "med_01HZX3K9",
  "media_type": "image",
  "operation": "upload",
  "mime_type": "image/png",
  "classification": "internal",
  "created_at": "2026-10-29T10:00:00Z"
}

DELETE /v1/media/{id}

Réponse :

{
  "deleted": true,
  "media_id": "med_01HZX3K9"
}

GET /v1/multimodal/jobs

Réponse :

{
  "items": [
    {
      "job_id": "mmj_V01",
      "operation": "video_process",
      "status": "running",
      "progress": 0.4
    }
  ],
  "next_cursor": null
}

Exemples SDK

Python

from enterprise_ai import EnterpriseAI

client = EnterpriseAI(base_url="<control-plane-url>", api_key="eai_live_xxx", tenant="acme", locale="fr")
client.multimodal.upload(open("invoice-scan.png", "rb").read(), "invoice-scan.png", "image/png", classification="internal")
client.multimodal.get_media(media_id="med_01HZX3K9")
client.multimodal.delete_media(media_id="med_01HZX3K9")
client.multimodal.jobs(status="running", limit=50)

TypeScript

import { EnterpriseAI } from "@enterprise-ai/sdk";

const client = new EnterpriseAI({ baseUrl: "<control-plane-url>", apiKey: process.env.EAI_API_KEY, tenant: "acme", locale: "fr" });
await client.media.upload({ file: new Blob([await readFile("invoice-scan.png")], { type: "image/png" }), filename: "invoice-scan.png", operation: "vision_understanding", classification: "internal" });
await client.media.get("med_01HZX3K9");
await client.media.delete("med_01HZX3K9");
await client.multimodal.listJobs({ status: "running", limit: 50 });

Java

EnterpriseAIClient client = EnterpriseAIClient.builder()
    .baseUrl("<control-plane-url>")
    .apiKey(System.getenv("EAI_API_KEY"))
    .tenant("acme")
    .locale(Locale.FRENCH)
    .build();
client.media().upload(Map.of("content_base64", Base64.getEncoder().encodeToString(Files.readAllBytes(Path.of("invoice-scan.png"))), "mime_type", "image/png", "filename", "invoice-scan.png", "classification", "internal"));
client.media().get("med_01HZX3K9");
client.media().delete("med_01HZX3K9");
client.multimodal().jobs(Map.of("status", "running", "limit", 50));

Go

client, err := eai.NewClient(eai.WithBaseURL("<control-plane-url>"), eai.WithAPIKey(os.Getenv("EAI_API_KEY")), eai.WithTenant("acme"), eai.WithLocale("fr"))
if err != nil { log.Fatal(err) }
ctx := context.Background()
_, err = client.Media.Upload(ctx, map[string]any{"content_base64": base64.StdEncoding.EncodeToString(scan), "mime_type": "image/png", "filename": "invoice-scan.png", "classification": "internal"})
_, err = client.Media.Get(ctx, "med_01HZX3K9")
err = client.Media.Delete(ctx, "med_01HZX3K9")
_, err = client.Multimodal.Jobs(ctx, eai.WithQuery(map[string]string{"status": "running", "limit": "50"}))

// worker package: run a media worker consuming multimodal jobs
w, err := worker.New(worker.Config{Source: jobs, Handler: handle, Client: client, Concurrency: 2})
if err != nil { log.Fatal(err) }
err = w.Run(ctx)

Configuration

Variables d'environnement : EAI_S3_ENDPOINT, EAI_S3_BUCKET, EAI_MEDIA_MAX_BYTES, EAI_NATS_URL.

Clés de valeurs Helm (deploy/helm/enterprise-ai/values.yaml) : controlPlane.config.EAI_S3_ENDPOINT, workers.enabled, workers.items.

Sécurité

• Métadonnées EXIF et GPS supprimées par défaut ; type de fichier vérifié par le contenu, pas l'extension.
• Préfixe et clé par tenant ; RLS sur eai.media.
• Tenant déduit de l'identifiant d'accès, jamais du corps ; sécurité au niveau des lignes PostgreSQL sur chaque table de tenant.
• Chaque mutation et décision de politique écrit un événement d'audit chaîné par hachage (G-11).
• Les erreurs utilisent l'enveloppe standard avec message_i18n en et fr.

Observabilité

• Retard de file par flux, taux de succès des jobs, croissance du stockage par tenant.
• traceparent W3C propagé, X-Request-Id renvoyé, les spans portent eai.tenant_id, eai.project, eai.agent_id, eai.run_id.

Unités FinOps

• storage_gb_hours et bytes_transferred par média, imputés au tenant et au projet.

Modes de défaillance et résilience

• Antivirus positif -> média en quarantaine, incident créé, l'upload renvoie validation_error.
• Stockage objet indisponible -> uploads refusés en 503 avec Retry-After, aucune ligne partielle.

Adoption autonome

Toutes les autres briques F en dépendent ; elle peut aussi servir seule de coffre média conforme.

Tests d'acceptation

1. Le fichier de test EICAR est mis en quarantaine.
2. DELETE /v1/media/{id} supprime l'objet et écrit un événement d'audit ; une conservation légale bloque la suppression.

Feuille de route d'implémentation

Preuves vocales du kit L4

Images de vidéo extraites par le vrai ffmpeg puis analysées par l'adaptateur de vision face à un faux VLM (tests/test_multimodal_video_vision.py, MULT-007 ; vrai VLM bloqué par le GPU et les poids). Voir le guide du runtime vocal.