Storage Adapters

npm install @mastra/pg

import { PgStorage } from '@mastra/pg';

// Connection string
const storage = new PgStorage({
  connectionString: process.env.DATABASE_URL,
});

// Or explicit configuration
const storage = new PgStorage({
  host: 'localhost',
  port: 5432,
  database: 'mastra',
  user: 'postgres',
  password: 'password',
  schemaName: 'public',  // Optional: custom schema
});

// With connection pool options
const storage = new PgStorage({
  connectionString: process.env.DATABASE_URL,
  max: 20,                    // Max connections
  idleTimeoutMillis: 30000,   // Idle timeout
});

import { exportSchemas } from '@mastra/pg';

// Export DDL for all tables
const ddl = exportSchemas('mastra');
fs.writeFileSync('schema.sql', ddl);

npm install @mastra/libsql

import { LibSQLStorage } from '@mastra/libsql';

// Remote (Turso)
const storage = new LibSQLStorage({
  url: process.env.TURSO_URL,
  authToken: process.env.TURSO_TOKEN,
});

// Local file
const storage = new LibSQLStorage({
  url: 'file:local.db',
});

// In-memory
const storage = new LibSQLStorage({
  url: ':memory:',
});

npm install @mastra/mongodb

import { MongoStorage } from '@mastra/mongodb';

// MongoDB Atlas
const storage = new MongoStorage({
  uri: process.env.MONGODB_URI,
  database: 'mastra',
});

// Local MongoDB
const storage = new MongoStorage({
  uri: 'mongodb://localhost:27017',
  database: 'mastra',
});

// With options
const storage = new MongoStorage({
  uri: process.env.MONGODB_URI,
  database: 'mastra',
  maxPoolSize: 10,
  minPoolSize: 2,
});

npm install @mastra/upstash

import { UpstashStorage } from '@mastra/upstash';

const storage = new UpstashStorage({
  url: process.env.UPSTASH_REDIS_REST_URL,
  token: process.env.UPSTASH_REDIS_REST_TOKEN,
});

npm install @mastra/dynamodb

import { DynamoDBStorage } from '@mastra/dynamodb';

const storage = new DynamoDBStorage({
  region: 'us-east-1',
  tableName: 'mastra-data',
  // Uses AWS credentials from environment
});

npm install @mastra/cloudflare-d1

import { D1Storage } from '@mastra/cloudflare-d1';

// In Cloudflare Worker
export default {
  async fetch(request, env) {
    const storage = new D1Storage({
      database: env.DB,  // D1 database binding
    });
    
    const mastra = new Mastra({ storage });
    // ...
  },
};

npm install @mastra/convex

import { ConvexStorage } from '@mastra/convex';

const storage = new ConvexStorage({
  url: process.env.CONVEX_URL,
});

const storage = new PgStorage({
  primary: process.env.DATABASE_URL,
  replicas: [
    process.env.READ_REPLICA_US,
    process.env.READ_REPLICA_EU,
  ],
  // Reads go to replicas, writes to primary
});

const storage = new MongoStorage({
  uri: process.env.MONGODB_URI,
  database: 'mastra',
  readPreference: 'primaryPreferred',
});

import { PgStorage } from '@mastra/pg';
import { MongoStorage } from '@mastra/mongodb';

const source = new PgStorage({ /* ... */ });
const target = new MongoStorage({ /* ... */ });

// Migrate memory threads
const threads = await source.memory.getThreads();

for (const thread of threads) {
  const messages = await source.memory.getMessages({ 
    threadId: thread.id 
  });
  
  await target.memory.saveMessages(thread.id, messages);
}

console.log(`Migrated ${threads.length} threads`);

const storage = new PgStorage({
  connectionString: process.env.DATABASE_URL,
  max: 20,                  // Max pool size
  min: 5,                   // Min pool size
  idleTimeoutMillis: 30000, // Idle timeout
  connectionTimeoutMillis: 2000,  // Connection timeout
});

-- PostgreSQL example
CREATE INDEX idx_messages_thread_id ON messages(thread_id);
CREATE INDEX idx_messages_created_at ON messages(created_at);
CREATE INDEX idx_workflows_status ON workflow_runs(status);
CREATE INDEX idx_workflows_created_at ON workflow_runs(created_at);

// Limit results for pagination
const messages = await storage.memory.getMessages({
  threadId,
  limit: 50,
  offset: 0,
});

// Filter by date range
const recentRuns = await storage.workflows.getRuns({
  workflowId,
  startTime: new Date('2024-01-01'),
  endTime: new Date('2024-12-31'),
});