Supercharge Your AI Applications: AWS Bedrock, MongoDB, and TypeScript

1
{
2
  "fields": [
3
    {
4
      "type": "vector",
5
      "path": "embedding",
6
      "numDimensions": 1024,
7
      "similarity": "cosine"
8
    },
9
    {
10
      "type": "filter",
11
      "path": "metadata"
12
    },
13
    {
14
      "type": "filter",
15
      "path": "text"
16
    }
17
  ]
18
}

1
mkdir youtube-search-lambda 
2
cd youtube-search-lambda 
3
npm init -y
4
npm install axios 
5
npm install --save-dev typescript @types/node @types/aws-lambda

1
{
2
  "compilerOptions": {
3
    "target": "es2018",
4
    "module": "commonjs",
5
    "strict": true,
6
    "esModuleInterop": true,
7
    "outDir": "./dist",
8
    "rootDir": "./src"
9
  },
10
  "include": ["src/**/*"],
11
  "exclude": ["node_modules"]
12
}

1
import axios from 'axios';
2
3
interface Event {
4
  agent: string;
5
  actionGroup: string;
6
  function: string;
7
  parameters: { name: string; value: string }[];
8
  messageVersion: string;
9
}
10
11
interface Context {
12
  // Add any necessary context properties
13
}
14
15
interface Video {
16
  title: string;
17
  description: string;
18
  thumbnail: string;
19
  video_id: string;
20
  url: string;
21
}
22
23
interface SearchResult {
24
  items: {
25
    id: { videoId: string };
26
    snippet: {
27
      title: string;
28
      description: string;
29
      thumbnails: {
30
        default: { url: string };
31
      };
32
    };
33
  }[];
34
}
35
36
export const handler = async (event: Event, context: Context): Promise<any> => {
37
  const { agent, actionGroup, function: functionName, parameters } = event;
38
39
  // Extract query and maxResults from parameters
40
  const query = parameters.find(param => param.name === 'query')?.value || 'AWS services';
41
  const maxResults = parseInt(parameters.find(param => param.name === 'maxResults')?.value || '5', 10);
42
43
  // YouTube Data API v3 search endpoint
44
  const apiKey = process.env.YOUTUBE_API_KEY;
45
  const baseUrl = 'https://www.googleapis.com/youtube/v3/search';
46
47
  // Construct the URL with query parameters
48
  const params = new URLSearchParams({
49
    part: 'snippet',
50
    q: query,
51
    type: 'video',
52
    maxResults: maxResults.toString(),
53
    key: apiKey!
54
  });
55
56
  try {
57
    // Make the API request
58
    const response = await axios.get<SearchResult>(`${baseUrl}?${params}`);
59
    const searchResults = response.data;
60
61
    // Process the search results
62
    const videos: Video[] = searchResults.items.map(item => ({
63
      title: item.snippet.title,
64
      description: item.snippet.description,
65
      thumbnail: item.snippet.thumbnails.default.url,
66
      video_id: item.id.videoId,
67
      url: `https://www.youtube.com/watch?v=${item.id.videoId}`
68
    }));
69
70
    // Prepare the response
71
    let responseText = `Here are ${videos.length} YouTube videos related to '${query}':\n\n`;
72
    videos.forEach((video, index) => {
73
      responseText += `${index + 1}. ${video.title}\n   ${video.url}\n\n`;
74
    });
75
76
    const actionResponse = {
77
      actionGroup,
78
      function: functionName,
79
      functionResponse: {
80
        responseBody: {
81
          TEXT: {
82
            body: responseText
83
          }
84
        }
85
      }
86
    };
87
88
    const functionResponse = { response: actionResponse, messageVersion: event.messageVersion };
89
    console.log(`Response: ${JSON.stringify(functionResponse)}`);
90
    return functionResponse;
91
  } catch (error) {
92
    console.error('Error:', error);
93
    throw error;
94
  }
95
};

1
"scripts": {
2
  "build": "tsc",
3
  "start": "node dist/index.js"
4
}

1
npm run build
2
cd dist
3
npm install --production
4
zip -r ../function.zip .

1
mkdir bedrock-ts-agent && cd bedrock-ts-agent

1
npm init -y

1
npm install express dotenv @aws-sdk/client-bedrock-agent-runtime
2
npm install -D typescript @types/express @types/node ts-node

1
npx tsc --init

1
{
2
  "compilerOptions": {
3
    "target": "es6",
4
    "module": "commonjs",
5
    "outDir": "./dist",
6
    "rootDir": "./src",
7
    "strict": true,
8
    "esModuleInterop": true
9
  },
10
  "include": ["src/**/*"],
11
  "exclude": ["node_modules"]
12
}

1
mkdir src && touch src/app.ts

1
import express from 'express';
2
import dotenv from 'dotenv';
3
import { BedrockAgentRuntimeClient, InvokeAgentCommand } from '@aws-sdk/client-bedrock-agent-runtime';
4
5
dotenv.config();
6
7
const app = express();
8
app.use(express.json());
9
10
const bedrockAgentRuntime = new BedrockAgentRuntimeClient({
11
  region: process.env.AWS_REGION || 'us-east-1',
12
  credentials: {
13
    accessKeyId: process.env.AWS_ACCESS_KEY_ID || '',
14
    secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY || '',
15
  },
16
});
17
18
const AGENT_ID = process.env.AGENT_ID || '';
19
const AGENT_ALIAS_ID = process.env.AGENT_ALIAS_ID || '';
20
21
async function invokeBedrockAgent(prompt: string, sessionId: string): Promise<{ sessionId: string; completion: string }> {
22
  const command = new InvokeAgentCommand({
23
    agentId: AGENT_ID,
24
    agentAliasId: AGENT_ALIAS_ID,
25
    sessionId,
26
    inputText: prompt,
27
  });
28
29
  try {
30
    let completion = "";
31
    const response = await bedrockAgentRuntime.send(command);
32
33
    if (response.completion === undefined) {
34
      throw new Error("Completion is undefined");
35
    }
36
37
    for await (let chunkEvent of response.completion) {
38
      const chunk = chunkEvent.chunk;
39
      if (chunk && chunk.bytes) {
40
        const decodedResponse = new TextDecoder("utf-8").decode(chunk.bytes);
41
        completion += decodedResponse;
42
      }
43
    }
44
45
    return { sessionId, completion };
46
  } catch (err) {
47
    console.error(err);
48
    throw err;
49
  }
50
}
51
52
app.post('/chat', async (req, res) => {
53
  try {
54
    const { message, sessionId } = req.body;
55
56
    if (!message || !sessionId) {
57
      return res.status(400).json({ error: 'Message and sessionId are required.' });
58
    }
59
60
    const response = await invokeBedrockAgent(message, sessionId);
61
    res.json(response);
62
  } catch (error) {
63
    console.error('Error:', error);
64
    res.status(500).json({ error: 'An error occurred while processing your request.' });
65
  }
66
});
67
68
const PORT = process.env.PORT || 3000;
69
app.listen(PORT, () => {
70
  console.log(`Server is running on port ${PORT}`);
71
});

1
AWS_REGION=us-east-1
2
AWS_ACCESS_KEY_ID=your_access_key_id
3
AWS_SECRET_ACCESS_KEY=your_secret_access_key
4
AGENT_ID=your_agent_id
5
AGENT_ALIAS_ID=your_agent_alias_id

1
"scripts": {
2
  "build": "tsc",
3
  "start": "node dist/app.js",
4
  "dev": "ts-node src/app.ts"
5
}

1
npm run build

1
npm start

1
curl -X POST http://localhost:3000/chat \
2
-H "Content-Type: application/json" \
3
-d '{"message": "Find me AWS formation talks and videos", "sessionId": "test-session-1"}'
4
5
{"sessionId":"test-session-1","completion":"Certainly! I've found some excellent AWS CloudFormation talks and videos that can help you learn about this important AWS service. AWS CloudFormation is a powerful tool for infrastructure as code, allowing you to model and provision your AWS resources easily. Here's a summary of the videos I found:\n\n1. For beginners, there's a step-by-step tutorial on creating and deleting an AWS CloudFormation stack. This video will give you hands-on experience with the basics of CloudFormation.\n\n2. If you're looking for a comprehensive introduction, there's an AWS CloudFormation tutorial by Intellipaat that covers the fundamentals of the service.\n\n3. For those interested in more advanced topics, there's an AWS re:Invent 2020 talk about building your first AWS CloudFormation resource provider. This is great for understanding how to extend CloudFormation's capabilities.\n\n4. Simplilearn offers an AWS CloudFormation tutorial and demo, which can provide practical insights into using the service.\n\n5. Lastly, there's a step-by-step tutorial specifically focused on creating a DynamoDB table using CloudFormation. This is excellent for understanding how CloudFormation can be used to provision specific AWS services.\n\nThese videos cover a range of topics from beginner to more advanced levels, providing a good mix of theoretical knowledge and practical demonstrations. They can help you understand how to use AWS CloudFormation to define and manage your infrastructure as code, which is a crucial skill for efficient cloud resource management.\n\nTo get started, I recommend watching these videos in order, starting with the beginner tutorials and progressing to the more advanced topics. This will give you a solid foundation in AWS CloudFormation and help you build your skills progressively.\n\nHere are the direct links to the videos for your convenience:\n\n1. [Create and Delete an AWS CloudFormation Stack | Step-by-Step Tutorial for Beginners](https://www.youtube.com/watch?v=fmDG-W5TFp4)\n2. [AWS CloudFormation | Introduction to AWS CloudFormation | AWS CloudFormation Tutorial | Intellipaat](https://www.youtube.com/watch?v=uunDvWG2hnE)\n3. [AWS re:Invent 2020: Build your first AWS CloudFormation resource provider](https://www.youtube.com/watch?v=qjtsuTVgrjs)\n4. [AWS CloudFormation Tutorial | AWS CloudFormation Demo | AWS Tutorial For Beginners | Simplilearn](https://www.youtube.com/watch?v=t97jZch4lMY)\n5. [AWS Cloudformation Step by Step Tutorial - Create a DynamoDB Table!](https://www.youtube.com/watch?v=YXVCdGyHDSk)\n\nEnjoy learning about AWS CloudFormation!"}