Tạo Lambda Function
Tải source code dưới đây:
-
Mở bảng điều khiển của AWS Lambda
-
Ấn Create function
- Nhập tên cho function:
search_docs
- Chọn Runtime là Python 3.9
- Ấn Create function
- Ấn Upload from, sau đó chọn .zip file
- Ấn Upload và chọn tệp search_docs.zip bạn vừa tải về. Tiếp theo ấn Save.
- Kéo xuống cuối trang, tại mục Runtime settings ấn Edit
- Thay lambda_function bằng
search_docs, sau đó ấn Save
- Tiếp theo chúng ta sẽ cập nhật quyền cho Lambda có thể truy cập vào OpenSearch domain.
- Chọn tab Configuration và chọn Permission ở menu phía bên trái
- Chọn role mà function đang thực hiện.
- Mở rộng policy và ấn Edit
- Sao chép script dưới đây và dán vào tab JSON. Sau đó ấn Review policy
,
{
"Effect": "Allow",
"Action": "es:*",
"Resource": "*"
}
- Ấn Save changes
- Tương tự chúng ta sẽ tạo một function để load streaming data từ DynamoDB vào OpenSearch instance.
- Trở lại với bảng điều khiển của AWS Lambda, ấn Create function
- Nhập tên cho function:
load_stream
- Chọn Runtime là Python 3.9
- Ấn Create function
- Ấn Upload from, sau đó chọn .zip file
- Ấn Upload và chọn tệp load_stream_data.zip bạn vừa tải về. Tiếp theo ấn Save.
- Kéo xuống cuối trang, tại mục Runtime settings ấn Edit
- Thay lambda_function bằng
load_stream_data, sau đó ấn Save
- Tiếp theo chúng ta sẽ cập nhật quyền cho Lambda có thể truy cập vào OpenSearch domain và DynamoDB.
- Chọn tab Configuration và chọn Permission ở menu phía bên trái
- Chọn role mà function đang thực hiện.
- Ấn Add permissions và chọn Attach policies
- Nhập tên policy
AmazonOpenSearchServiceFullAccessvà chọn policy đó
- Nhập tên policy
AWSLambdaDynamoDBExecutionRolevà chọn policy đó. Sau đó ấn Add permissions
- Mở bảng điều khiển của Amazon DynamoDB
- Chọn Tables | Update settings ở menu phía bên trái, sau đó chọn bảng Documents
- Ấn chọn tab Exports and streams
- Kéo xuống cuối, tại mục DynamoDB stream details, ấn Create trigger
- Nhập tên hàm Lambda:
load_stream- Nhập
1cho batch size - Ấn Create trigger
- Nhập
