Vue d’ensemble du stockage

Le stockage Mastra est organisé en domaines. Chaque domaine possède un ensemble de tables ou de collections. Selon votre adaptateur et votre configuration, vous pouvez utiliser tous les domaines ou seulement un sous-ensemble.

Domaines de stockage

MastraCompositeStore peut router les clés de domaine suivantes :

Tous les adaptateurs de stockage n’implémentent pas chaque domaine. Le stockage composite vous permet de mélanger les adaptateurs par domaine lorsque les packages d’adaptateurs exportent les classes de domaine correspondantes.

Domaine	Description
memory	Persistance des conversations : messages, fils de discussion et ressources (y compris la mémoire de travail).
workflows	Instantanés d’exécution de Workflow utilisés pour suspendre et reprendre.
workflowDefinitions	Définitions persistantes de Workflow dynamiques (bêta). Chargées et enregistrées dynamiquement au démarrage.
scores	Enregistrements des scores d’évaluation issus des exécutions d’eval.
observability	Traces et spans utilisés par les exportateurs d’observabilité et Studio.
datasets	Enregistrements de datasets, éléments versionnés et versions de datasets utilisés par les expériences.
experiments	Exécutions d’expériences et résultats d’expérience par élément.

Les définitions de schéma ci-dessous couvrent les tables intégrées adossées à une base de données documentées pour memory, workflows, scores et observability. Les autres domaines et les adaptateurs qui ne s’appuient pas sur une base de données utilisent des structures de stockage propres à leur implémentation.

Schéma central

Messages

Stocke les messages de conversation et leurs métadonnées. Chaque message appartient à un fil de discussion et contient le contenu réel ainsi que des métadonnées sur le rôle de l’expéditeur et le type de message.

id

uuidv4

PRIMARYKEY

NOT NULL

Identifiant unique du message (format : xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx)

thread_id

uuidv4

FK → threads.id

NOT NULL

Référence au fil de discussion parent

resourceId

uuidv4

CAN BE NULL

ID de la ressource propriétaire de ce message

content

text

NOT NULL

JSON du contenu du message au format V2. Exemple : { format: 2, parts: [...] }

role

text

NOT NULL

Énumération de user | assistant

createdAt

timestamp

NOT NULL

Utilisé pour l’ordre des messages du fil de discussion

La colonne content du message contient un objet JSON conforme au type MastraMessageContentV2, conçu pour correspondre étroitement à la structure de message UIMessage de l’AI SDK.

format

integer

NOT NULL

Version du format de message (actuellement 2)

parts

array (JSON)

NOT NULL

Tableau de parties de message (texte, appel d’outil, fichier, raisonnement, etc.). La structure des éléments de ce tableau varie selon type.

experimental_attachments

array (JSON)

CAN BE NULL

Tableau facultatif de pièces jointes

content

text

CAN BE NULL

Contenu textuel principal facultatif du message

toolInvocations

array (JSON)

CAN BE NULL

Tableau facultatif résumant les appels d’outils et leurs résultats

reasoning

object (JSON)

CAN BE NULL

Informations facultatives sur le processus de raisonnement derrière la réponse de l’assistant

annotations

object (JSON)

CAN BE NULL

Métadonnées ou annotations supplémentaires facultatives

Fils de discussion

Regroupe les messages liés et les associe à une ressource. Contient des métadonnées sur la conversation.

id

uuidv4

PRIMARYKEY

NOT NULL

Identifiant unique du fil de discussion (format : xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx)

resourceId

text

NOT NULL

Identifiant principal de la ressource externe associée à ce fil de discussion. Utilisé pour regrouper et récupérer les fils de discussion liés.

title

text

NOT NULL

Titre du fil de discussion

metadata

text

Métadonnées personnalisées du fil de discussion sous forme de JSON sérialisé. Exemple :

{
  "category": "support",
  "priority": 1
}

createdAt

timestamp

NOT NULL

updatedAt

timestamp

NOT NULL

Utilisé pour l’historique d’ordre des fils de discussion

Ressources

Stocke des données propres à l’utilisateur pour la mémoire de travail limitée à une ressource. Chaque ressource représente un utilisateur ou une entité, ce qui permet à la mémoire de travail de persister dans tous les fils de discussion de cet utilisateur.

id

text

PRIMARYKEY

NOT NULL

Identifiant de ressource (ID utilisateur ou entité) : identique à resourceId utilisé dans les fils de discussion et les appels d’agent

workingMemory

text

CAN BE NULL

Données de mémoire de travail persistante sous forme de texte Markdown. Contient le profil utilisateur, les préférences et les informations contextuelles qui persistent dans les fils de discussion.

metadata

jsonb

CAN BE NULL

Métadonnées de ressource supplémentaires au format JSON. Exemple :

{
  "preferences": {
    "language": "en",
    "timezone": "UTC"
  },
  "tags": [
    "premium",
    "beta-user"
  ]
}

createdAt

timestamp

NOT NULL

Date de création initiale de l’enregistrement de ressource

updatedAt

timestamp

NOT NULL

Date de la dernière mise à jour de la mémoire de travail

Workflows

Lorsque suspend() est appelé sur un workflow, son état est enregistré au format suivant. Lorsque resume() est appelé, cet état est réhydraté.

workflow_name

text

NOT NULL

Nom du workflow

run_id

uuidv4

NOT NULL

Identifiant unique de l’exécution du workflow. Utilisé pour suivre l’état entre les cycles de suspension/reprise (format : xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx)

snapshot

text

NOT NULL

État sérialisé du workflow au format JSON. Exemple :

{
  "value": {
    "currentState": "running"
  },
  "context": {
    "stepResults": {},
    "attempts": {},
    "triggerData": {}
  },
  "activePaths": [],
  "runId": "550e8400-e29b-41d4-a716-446655440000",
  "timestamp": 1648176000000
}

createdAt

timestamp

NOT NULL

updatedAt

timestamp

NOT NULL

Date de dernière modification, utilisée pour suivre les changements d’état pendant l’exécution du workflow

Evals

Stocke les résultats d’eval obtenus en exécutant des métriques sur les sorties d’agent.

input

text

NOT NULL

Entrée fournie à l’agent

output

text

NOT NULL

Sortie générée par l’agent

result

jsonb

NOT NULL

Données de résultat d’eval incluant le score et les détails. Exemple :

{
  "score": 0.95,
  "details": {
    "reason": "Response accurately reflects source material",
    "citations": [
      "page 1",
      "page 3"
    ]
  }
}

agent_name

text

NOT NULL

metric_name

text

NOT NULL

Par exemple : Faithfulness, Hallucination, etc.

instructions

text

NOT NULL

Prompt système ou instructions pour l’agent

test_info

jsonb

NOT NULL

Métadonnées et configuration de test supplémentaires

global_run_id

uuidv4

NOT NULL

Regroupe les exécutions d’évaluation liées (par exemple, tous les tests unitaires d’une exécution CI)

run_id

uuidv4

NOT NULL

Identifiant unique de l’exécution évaluée (format : xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx)

created_at

timestamp

NOT NULL

Traces

Capture les traces OpenTelemetry pour la surveillance et le débogage.

id

text

NOT NULL

PRIMARYKEY

Identifiant de trace unique

parentSpanId

text

ID du span parent. Null si le span est de niveau supérieur

name

text

NOT NULL

Nom d’opération hiérarchique (par exemple, workflow.myWorkflow.execute, http.request, database.query)

traceId

text

NOT NULL

Identifiant de trace racine qui regroupe les spans liés

scope

text

NOT NULL

Bibliothèque/package/service qui a créé le span (par exemple, @mastra/core, express, pg)

kind

integer

NOT NULL

INTERNAL (0, dans le processus), CLIENT (1, appels sortants), SERVER (2, appels entrants), PRODUCER (3, création de tâche asynchrone), CONSUMER (4, traitement de tâche asynchrone)

attributes

jsonb

Paires clé-valeur définies par l’utilisateur contenant des métadonnées de span

status

jsonb

Objet JSON avec code (UNSET=0, ERROR=1, OK=2) et message facultatif. Exemple :

{
  "code": 1,
  "message": "HTTP request failed with status 500"
}

events

jsonb

Événements horodatés survenus pendant le span

links

jsonb

Liens vers d’autres spans liés

other

text

Champs de span OpenTelemetry supplémentaires sous forme de JSON sérialisé. Exemple :

{
  "droppedAttributesCount": 2,
  "droppedEventsCount": 1,
  "instrumentationLibrary": "@opentelemetry/instrumentation-http"
}

startTime

bigint

NOT NULL

Nanosecondes écoulées depuis l’époque Unix au démarrage du span

endTime

bigint

NOT NULL

Nanosecondes écoulées depuis l’époque Unix à la fin du span

createdAt

timestamp

NOT NULL