教程：使用 Amazon OpenSearch Service 创建搜索应用程序

创建部署包

1. 打开命令提示符并创建 my-opensearch-function 项目目录。例如，在 macOS 上，请执行以下操作：

   mkdir my-opensearch-function

2. 导航到 my-sourcecode-function 项目目录。

   cd my-opensearch-function

3. 复制以下 Python 示例代码的内容，并且使用名为 opensearch-lambda.py 的新文件将其保存。将您的区域和主机端点添加到文件中。

   import boto3
   import json
   import requests
   from requests_aws4auth import AWS4Auth
   
   region = '' # For example, us-west-1
   service = 'es'
   credentials = boto3.Session().get_credentials()
   awsauth = AWS4Auth(credentials.access_key, credentials.secret_key, region, service, session_token=credentials.token)
   
   host = '' # The OpenSearch domain endpoint with https:// and without a trailing slash
   index = 'movies'
   url = host + '/' + index + '/_search'
   
   # Lambda execution starts here
   def lambda_handler(event, context):
   
       # Put the user query into the query DSL for more accurate search results.
       # Note that certain fields are boosted (^).
       query = {
           "size": 25,
           "query": {
               "multi_match": {
                   "query": event['queryStringParameters']['q'],
                   "fields": ["title^4", "plot^2", "actors", "directors"]
               }
           }
       }
   
       # Elasticsearch 6.x requires an explicit Content-Type header
       headers = { "Content-Type": "application/json" }
   
       # Make the signed HTTP request
       r = requests.get(url, auth=awsauth, headers=headers, data=json.dumps(query))
   
       # Create the response and add some extra content to support CORS
       response = {
           "statusCode": 200,
           "headers": {
               "Access-Control-Allow-Origin": '*'
           },
           "isBase64Encoded": False
       }
   
       # Add the search results to the response
       response['body'] = r.text
       return response

4. 在新的 package 目录中安装外部库。

   pip3 install --target ./package boto3
   pip3 install --target ./package requests
   pip3 install --target ./package requests_aws4auth

5. 使用已安装库在根目录下创建部署程序包。以下命令可在项目目录中生成 my-deployment-package.zip 文件。

   cd package
   zip -r ../my-deployment-package.zip .

6. 将 opensearch-lambda.py 文件添加到 zip 文件的根目录。

   cd ..
   zip my-deployment-package.zip opensearch-lambda.py

1. 导航到 Lambda 控制台：https://console.aws.amazon.com/lambda/home。在左侧导航窗格中，选择函数。

2. 选择创建函数。

3. 配置以下字段：

   • 函数名称：opensearch-function

   • 运行时：Python 3.9

   • 架构：x86_64

   保留所有其他默认选项，然后选择创建函数。

4. 在函数摘要页面的代码源部分，选择从下拉列表中上传，然后选择 .zip 文件。找到您创建的 my-deployment-package.zip 文件，然后选择保存。

5. 处理程序是函数代码中处理事件的方法。在运行时设置下，选择编辑，根据 Lambda 函数所在的部署包中的文件名更改处理程序名称。鉴于您的文件名为 opensearch-lambda.py，请将处理程序重命名为 opensearch-lambda.lambda_handler。有关更多信息，请参阅 Python 中的 Lambda 函数处理程序中的。

1. 通过以下网址导航到 API Gateway 控制台：https://console.aws.amazon.com/apigateway/home。在左侧导航窗格中，选择 APIs。

2. 定位REST API（非私有），然后选择构建。

3. 在下一页中，找到新建 API 部分，确保选中新建 API。

4. 配置以下字段：

   • API 名称：opensearch-api

   • 描述：用于搜索 Amazon OpenSearch Service 域的公共 API

   • 端点类型：区域

5. 选择创建 API。

6. 选择操作和创建方法。

7. 在下拉菜单中选择GET，然后单击复选标记进行确认。

8. 配置以下设置，然后选择保存：

1. 选择操作和部署 API。

2. 对于部署阶段选择新阶段并将阶段命名为 opensearch-api-test。

3. 选择 Deploy（部署）。

4. 在阶段编辑器中配置以下设置，然后选择保存更改：

1. 导航到域的 OpenSearch 控制面板 URL。

2. 从主菜单中，选择安全、角色，然后选择 all_access 链接和需要将 Lambda 角色映射到的角色。

3. 选择映射的用户、管理映射。

4. 在 Backend roles（后端角色）下，添加 Lambda 角色的 Amazon 资源名称（ARN）。ARN 应采用 arn:aws:iam::123456789123:role/service-role/opensearch-lambda-role-1abcdefg 形式。

5. 选择映射并确认在映射的用户下显示的用户或角色。

测试 Web 应用程序

1. 下载 sample-site.zip，解压后在常用文本编辑器中打开 scripts/search.js。

2. 更新 apigatewayendpoint 变量以指向您的 API Gateway 端点，并在给定路径末尾添加反斜线。您可以选择阶段，然后选择 API 的名称，即可在 API Gateway 中快速找到端点。apigatewayendpoint 变量应采用 https://some-id.execute-api.us-west-1.amazonaws.com/opensearch-api-test/ 形式。

3. 打开 index.html 并尝试运行对 thor、house 和其他几个术语的搜索。

   

1. 在 GET 资源上启用 CORS。在 Advanced (高级) 西方，设置 Access-Control-Allow-Credentials 为 'true'。

2. 在 API Gateway 中重新部署 API (Action (操作)、Deploy API (部署 API))。

3. 删除并重新添加 Lambda 函数触发器。重新添加，选择添加触发器并创建调用函数的 HTTP 端点。该触发器必须具有以下配置：

   触发器	API	部署阶段	安全性
   API Gateway	opensearch-api	opensearch-api-test	打开