POST /v1/capture

Ingestion idempotente d’un lot d’événements. Répond 202 dès l’écriture faite ; la consolidation part en tâche de fond (job pending, traité par POST /v1/consolidate — voir Consolidator).

Corps de la requête

EventIn[]

requis

Un ou plusieurs événements (min_length=1).

Afficher champs de EventIn

string

requis

1 à 128 caractères.

string

requis

1 à 128 caractères.

string

défaut:"user"

Max 64 caractères.

string

Max 128 caractères. Non marqué requis par Pydantic mais validé par le Ledger (missing_scope si vide) — pour produire une erreur avec l’index exact de l’événement en cause dans le lot.

string

Max 64 caractères.

string

Max 128 caractères.

string

Max 128 caractères.

string

Max 128 caractères.

string

Max 128 caractères.

string

requis

1 à 128 caractères. Libre — ex. conversation.message, conversation.turn, agent.observation.

datetime

requis

ISO 8601.

object

requis

Contenu libre.

object

Provenance libre, ex. {"tool": "mcp", "server": "haki"}.

string[]

défaut:"[]"

Étiquettes libres.

string

Max 128 caractères.

string

Max 256 caractères. Clé par événement (voir Memory Ledger pour l’ordre de priorité avec la clé de lot).

string

Max 256 caractères. Clé de lot : namespacée par le hash de contenu de chaque événement, donc plusieurs événements du même lot ne collisionnent jamais entre eux.

Réponse — `202 Accepted`

string

défaut:"accepted"

CapturedEvent[]

requis

Afficher champs

uuid

requis

boolean

requis

true si cet événement existait déjà (même clé d’idempotence) — la ligne renvoyée est l’originale, aucune nouvelle écriture.

uuid | null

null si tout le lot était dupliqué — rien de nouveau à consolider.

string

La policy appliquée (HAKI_DEFAULT_POLICY, "default" en local).

curl -X POST http://localhost:8100/v1/capture \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer hk_..." \
  -d '{
    "idempotency_key": "demo-1",
    "events": [{
      "org_id": "org_acme", "project_id": "prj_support",
      "subject_type": "user", "subject_id": "usr_42",
      "kind": "conversation.message",
      "occurred_at": "2026-08-01T10:00:00Z",
      "payload": {"role": "user", "content": "Je préfère mes factures en français."},
      "classification": ["customer-data"]
    }]
  }'

client.capture(
    events=[{
        "org_id": "org_acme", "project_id": "prj_support",
        "subject_type": "user", "subject_id": "usr_42",
        "kind": "conversation.message",
        "occurred_at": "2026-08-01T10:00:00Z",
        "payload": {"role": "user", "content": "Je préfère mes factures en français."},
    }],
    idempotency_key="demo-1",
)

{
  "status": "accepted",
  "events": [{"id": "7c21e4c2-...", "deduplicated": false}],
  "consolidation_job_id": "9b0f1a3e-...",
  "policy": "default"
}

Erreurs possibles

missing_scope (subject_id vide sur un événement — 422), forbidden_scope (un project_id d’événement ≠ celui de la clé — 403), invalid_payload (corps malformé — 422).

Demarrer

Memoire

Qualite et correction

Administration

Gateway et sante

POST /v1/capture

Corps de la requête

Réponse — `202 Accepted`

Erreurs possibles

​Corps de la requête

​Réponse — 202 Accepted

​Erreurs possibles

Corps de la requête

Réponse — `202 Accepted`

Erreurs possibles