MastraStorage

MastraStorage は、以下の管理のための統一されたインターフェースを提供します：

中断されたワークフロー: 中断されたワークフローのシリアライズされた状態（後で再開できるように）
メモリ: アプリケーション内のresourceIdごとのスレッドとメッセージ
トレース: MastraのすべてのコンポーネントからのOpenTelemetryトレース
評価データセット: 評価実行からのスコアとスコアリングの理由

Mastraは異なるストレージプロバイダーを提供しますが、それらを交換可能として扱うことができます。例えば、開発中はlibsqlを使用し、本番環境ではpostgresを使用することができ、どちらの場合でもコードは同じように動作します。

設定

Mastraはデフォルトのストレージオプションで設定できます：


import { Mastra } from "@mastra/core/mastra";
import { LibSQLStore } from "@mastra/libsql";
 
const mastra = new Mastra({
  storage: new LibSQLStore({
    url: "file:./mastra.db",
  }),
});

データスキーマ

Messages

会話メッセージとそのメタデータを保存します。各メッセージはスレッドに属し、送信者の役割やメッセージタイプに関するメタデータと共に実際のコンテンツを含みます。

uuidv4

PRIMARYKEY

NOT NULL

メッセージの一意の識別子（形式: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx）

thread_id

uuidv4

FK → threads.id

NOT NULL

親スレッドの参照

content

text

NOT NULL

role

text

NOT NULL

system | user | assistant | tool の列挙型

type

text

NOT NULL

text | tool-call | tool-result の列挙型

createdAt

timestamp

NOT NULL

スレッドメッセージの順序付けに使用

Threads

関連するメッセージをまとめてリソースに関連付けます。会話に関するメタデータを含みます。

uuidv4

PRIMARYKEY

NOT NULL

スレッドの一意の識別子（形式: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx）

resourceId

text

NOT NULL

このスレッドが関連付けられている外部リソースの主識別子。関連するスレッドをグループ化および取得するために使用。

title

text

NOT NULL

会話スレッドのタイトル

metadata

text

文字列化されたJSONとしてのカスタムスレッドメタデータ。例:


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

createdAt

timestamp

NOT NULL

updatedAt

timestamp

NOT NULL

スレッドの順序履歴に使用

Workflows

workflowでsuspendが呼び出されると、その状態は次の形式で保存されます。resumeが呼び出されると、その状態が再構築されます。

workflow_name

text

NOT NULL

ワークフローの名前

run_id

uuidv4

NOT NULL

ワークフロー実行の一意の識別子。suspend/resumeサイクル間で状態を追跡するために使用（形式: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx）

snapshot

text

NOT NULL

JSONとしてシリアライズされたワークフロー状態。例:


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

createdAt

timestamp

NOT NULL

updatedAt

timestamp

NOT NULL

ワークフロー実行中の状態変化を追跡するための最終変更時間

Eval Datasets

エージェントの出力に対してメトリクスを実行した評価結果を保存します。

input

text

NOT NULL

エージェントに提供された入力

output

text

NOT NULL

エージェントによって生成された出力

result

jsonb

NOT NULL

スコアと詳細を含む評価結果データ。例:


{
  "score": 0.95,
  "details": {
    "reason": "応答が元の資料を正確に反映している",
    "citations": [
      "ページ 1",
      "ページ 3"
    ]
  }
}

agent_name

text

NOT NULL

metric_name

text

NOT NULL

例: Faithfulness, Hallucination など

instructions

text

NOT NULL

エージェントへのシステムプロンプトまたは指示

test_info

jsonb

NOT NULL

追加のテストメタデータと構成

global_run_id

uuidv4

NOT NULL

関連する評価実行をグループ化します（例: CI 実行内のすべての単体テスト）

run_id

uuidv4

NOT NULL

評価される実行の一意の識別子（形式: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx）

created_at

timestamp

NOT NULL

Traces

OpenTelemetryのトレースをキャプチャして、モニタリングとデバッグを行います。

text

NOT NULL

PRIMARYKEY

ユニークなトレース識別子

parentSpanId

text

親スパンのID。スパンがトップレベルの場合はNull

name

text

NOT NULL

階層的な操作名（例: workflow.myWorkflow.execute, http.request, database.query）

traceId

text

NOT NULL

関連するスパンをグループ化するルートトレース識別子

scope

text

NOT NULL

スパンを作成したライブラリ/パッケージ/サービス（例: @mastra/core, express, pg）

kind

integer

NOT NULL

INTERNAL (0, プロセス内), CLIENT (1, 外部呼び出し), SERVER (2, 受信呼び出し), PRODUCER (3, 非同期ジョブ作成), CONSUMER (4, 非同期ジョブ処理)

attributes

jsonb

スパンのメタデータを含むユーザー定義のキーと値のペア

status

jsonb

code (UNSET=0, ERROR=1, OK=2) とオプションの message を含むJSONオブジェクト。例:


{
  "code": 1,
  "message": "HTTPリクエストがステータス500で失敗しました"
}

events

jsonb

スパン中に発生したタイムスタンプ付きイベント

links

jsonb

他の関連するスパンへのリンク

other

text

文字列化されたJSONとしての追加のOpenTelemetryスパンフィールド。例:


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

startTime

bigint

NOT NULL

スパンが開始されたUnixエポックからのナノ秒

endTime

bigint

NOT NULL

スパンが終了したUnixエポックからのナノ秒

createdAt

timestamp

NOT NULL

ストレージプロバイダー

Mastraは以下のプロバイダーをサポートしています：

ローカル開発には、LibSQL Storageをチェックしてください
本番環境には、PostgreSQL Storageをチェックしてください
サーバーレスデプロイメントには、Upstash Storageをチェックしてください