Replace mastra to Strands Agents for AgentCore Runtime example

Author: poad

amplify/amplify-cdk/app/package.json

@@ -21,7 +21,7 @@
     "@mui/material": "^9.0.0",
     "autoprefixer": "^10.5.0",
     "next": "^16.2.4",
-    "postcss": "^8.5.13",
+    "postcss": "^8",
     "react": "^19.2.5",
     "react-dom": "^19.2.5",
     "tailwindcss": "^4.2.4",

bedrock/agentcore-runtime-agent-example/app/Dockerfile

@@ -12,7 +12,7 @@ COPY package.json ./
 RUN npx -y pnpm@latest i
 COPY . ./
 
-RUN npx -y bun@latest run mastra build
+RUN npx -y bun@latest run tsc
 
 
 FROM --platform=$BUILDPLATFORM node:$NODE_VERSION-slim AS dev
@@ -28,10 +28,17 @@ ENV PORT=8080
 
 ENTRYPOINT ["npx", "-y", "pnpm", "dev"]
 
+FROM --platform=$BUILDPLATFORM node:$NODE_VERSION-slim AS base
 
-FROM --platform=$BUILDPLATFORM node:$NODE_VERSION-slim
+WORKDIR /var/task
+COPY package.json ./
+
+RUN npx -y pnpm@latest i --production
+RUN rm -rf package.json
+
+FROM --platform=$BUILDPLATFORM base
 
-COPY --from=build /build /var/task
+COPY --from=build /build/dist /var/task
 
 # Change ownership to non-root user
 RUN chown -R node:node /var/task
@@ -43,4 +50,4 @@ USER node
 
 ENV PORT=8080
 
-ENTRYPOINT [ "node", "--import=./.mastra/output/instrumentation.mjs", ".mastra/output/index.mjs" ]
+ENTRYPOINT [ "node", "./index.js" ]

bedrock/agentcore-runtime-agent-example/app/package.json

@@ -6,47 +6,38 @@
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",
     "clean": "tsc --build --clean",
-    "dev": "mastra dev",
-    "build": "mastra build",
-    "start": "mastra start",
+    "dev": "tsx src/index.ts",
+    "build": "tsc",
+    "start": "node dist/index.js",
     "lint": "eslint .",
     "lint-fix": "eslint . --fix"
   },
   "keywords": [],
   "author": "",
-  "license": "ISC",
   "type": "module",
   "engines": {
     "node": ">=24.0.0"
   },
   "dependencies": {
     "@ai-sdk/amazon-bedrock": "^4.0.96",
     "@aws-sdk/credential-providers": "^3.1041.0",
-    "@aws/aws-distro-opentelemetry-node-autoinstrumentation": "^0.10.0",
-    "@mastra/core": "^1.28.0",
-    "@mastra/duckdb": "^1.2.0",
-    "@mastra/evals": "^1.2.1",
-    "@mastra/libsql": "^1.9.0",
-    "@mastra/loggers": "^1.1.1",
-    "@mastra/mcp": "^1.5.2",
-    "@mastra/memory": "^1.17.1",
-    "@mastra/observability": "^1.10.0",
-    "@mastra/otel-exporter": "^1.0.17",
+    "@hono/node-server": "^1.19.14",
+    "@modelcontextprotocol/sdk": "^1.29.0",
+    "@strands-agents/sdk": "^0.7.0",
     "hono": "^4.12.16",
     "zod": "^4.4.2"
   },
   "devDependencies": {
     "@eslint/compat": "^2.0.5",
     "@eslint/js": "^10.0.1",
-    "@mastra/deployer": "^1.28.0",
     "@stylistic/eslint-plugin": "^5.10.0",
     "@types/node": "^24.12.2",
     "eslint": "^10.3.0",
     "eslint-import-resolver-typescript": "^4.4.4",
     "eslint-plugin-import-x": "^4.16.2",
     "eslint-plugin-promise": "^7.3.0",
     "jiti": "^2.6.1",
-    "mastra": "^1.6.3",
+    "tsx": "^4.21.0",
     "typescript": "^6.0.3",
     "typescript-eslint": "^8.59.1"
   }

…ample/app/src/mastra/agents/aws-agent.ts …gent-example/app/src/agents/aws-agent.tsbedrock/agentcore-runtime-agent-example/app/src/mastra/agents/aws-agent.ts renamed to bedrock/agentcore-runtime-agent-example/app/src/agents/aws-agent.ts bedrock/agentcore-runtime-agent-example/app/src/mastra/agents/aws-agent.ts renamed to bedrock/agentcore-runtime-agent-example/app/src/agents/aws-agent.ts

@@ -1,19 +1,15 @@
 import { tools } from '../tools/aws-tool.js';
-import { scorers } from '../scorers/aws-scorer.js';
-import { Agent } from '@mastra/core/agent';
-import { Memory } from '@mastra/memory';
-import { createAmazonBedrock } from '@ai-sdk/amazon-bedrock';
-import { fromNodeProviderChain } from '@aws-sdk/credential-providers';
+import { Agent, BedrockModel  } from '@strands-agents/sdk';
 
-const bedrock = createAmazonBedrock({
+const bedrockModel = new BedrockModel({
+  modelId: 'global.amazon.nova-2-lite-v1:0',
   region: 'us-east-1',
-  credentialProvider: fromNodeProviderChain(),
+  temperature: 0.3,
 });
-
 export const awsAgent = new Agent({
   id: 'aws-agent',
   name: 'AWS Agent',
-  instructions: `
+  systemPrompt: `
       You are an assistant that helps architects design systems using Amazon Web Services (AWS). Your primary function is to answer user questions based on AWS knowledge and propose system architectures. When responding, follow these guidelines:
 
       - If information is not available in aws-knowledge-mcp-server, clearly state that you don't know
@@ -25,30 +21,6 @@ export const awsAgent = new Agent({
       - For non-AWS information, use Context7 to resolve queries with up-to-date information
           - If Context7 cannot resolve the query, clearly state that you don't know
 `,
-  model: bedrock('global.amazon.nova-2-lite-v1:0'),
+  model: bedrockModel,
   tools,
-  scorers: {
-    toolCallAppropriateness: {
-      scorer: scorers.toolCallAppropriatenessScorer,
-      sampling: {
-        type: 'ratio',
-        rate: 1,
-      },
-    },
-    completeness: {
-      scorer: scorers.completenessScorer,
-      sampling: {
-        type: 'ratio',
-        rate: 1,
-      },
-    },
-    translation: {
-      scorer: scorers.translationScorer,
-      sampling: {
-        type: 'ratio',
-        rate: 1,
-      },
-    },
-  },
-  memory: new Memory(),
 });

bedrock/agentcore-runtime-agent-example/app/src/app.ts

@@ -0,0 +1,52 @@
+
+import { awsAgent } from './agents/aws-agent.js';
+import { mcp } from './tools/aws-tool.js';
+import { Hono } from 'hono';
+import { streamSSE } from 'hono/streaming';
+
+export const app = new Hono();
+
+app.get('/ping', (c) =>
+  c.json({
+    status: 'Healthy',
+    time_of_last_update: Math.floor(Date.now() / 1000),
+  }),
+);
+
+app.post('/invocations', async (c) => {
+  const body = await c.req.json();
+  // Input validation
+  if (!body || typeof body !== 'object') {
+    return c.json({ error: 'Invalid request body' }, 400);
+  }
+
+  const { prompt } = body;
+
+  if (!prompt || typeof prompt !== 'string') {
+    return c.json({ error: 'prompt is required and must be a string' }, 400);
+  }
+
+  if (prompt.length > 10000) { // Reasonable limit
+    return c.json({ error: 'prompt is too long' }, 400);
+  }
+
+  // ストリーミングレスポンス
+  try {
+    const streamResult = await awsAgent.stream(prompt);
+    for await (const event of streamResult) {
+      return streamSSE(c, async (stream) => {
+        if (
+          event.type === 'modelStreamUpdateEvent' &&
+          event.event.type === 'modelContentBlockDeltaEvent' &&
+          event.event.delta.type === 'textDelta'
+        ) {
+          await stream.write(event.event.delta.text);
+        }
+      });
+    }
+  } catch (e) {
+    await mcp.disconnect();
+    throw e;
+  }
+},
+);

bedrock/agentcore-runtime-agent-example/app/src/index.ts

@@ -0,0 +1,24 @@
+import { app } from './app.js';
+import { serve } from '@hono/node-server';
+
+const PORT = Number.parseInt(process.env.PORT ?? '8080');
+
+const server = serve(
+  { ...app, port: PORT }, (info) => {
+    console.log(`Server is running on http://localhost:${info.port}`);
+  });
+
+// graceful shutdown
+process.on('SIGINT', () => {
+  server.close();
+  process.exit(0);
+});
+process.on('SIGTERM', () => {
+  server.close((err) => {
+    if (err) {
+      console.error(err);
+      process.exit(1);
+    }
+    process.exit(0);
+  });
+});