文档 AWS SDK 示例 GitHub 存储库中还有更多 [S AWS DK 示例](https://github.com/awsdocs/aws-doc-sdk-examples)。
本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
# 使用 SDK for Kotlin 的 Lambda 示例
以下代码示例向您展示了如何使用带有 Lambda 的 Kotlin AWS 开发工具包来执行操作和实现常见场景。
*基本功能*是向您展示如何在服务中执行基本操作的代码示例。
*操作*是大型程序的代码摘录，必须在上下文中运行。您可以通过操作了解如何调用单个服务函数，还可以通过函数相关场景的上下文查看操作。
*场景*是向您演示如何通过在一个服务中调用多个函数或与其他 AWS 服务结合来完成特定任务的代码示例。
每个示例都包含一个指向完整源代码的链接，您可以从中找到有关如何在上下文中设置和运行代码的说明。
**Topics**
+ [基本功能](#basics)
+ [操作](#actions)
+ [场景](#scenarios)
## 基本功能
### 了解基本功能
以下代码示例展示了如何：
+ 创建 IAM 角色和 Lambda 函数，然后上传处理程序代码。
+ 使用单个参数来调用函数并获取结果。
+ 更新函数代码并使用环境变量进行配置。
+ 使用新参数来调用函数并获取结果。显示返回的执行日志。
+ 列出账户函数，然后清除函数。
有关更多信息，请参阅[使用控制台创建 Lambda 函数](https://docs.aws.amazon.com/lambda/latest/dg/getting-started-create-function.html)。
**适用于 Kotlin 的 SDK**
还有更多相关信息 GitHub。在 [AWS 代码示例存储库](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/lambda#code-examples)中查找完整示例，了解如何进行设置和运行。
```
suspend fun main(args: Array) {
val usage = """
Usage:
Where:
functionName - The name of the AWS Lambda function.
role - The AWS Identity and Access Management (IAM) service role that has AWS Lambda permissions.
handler - The fully qualified method name (for example, example.Handler::handleRequest).
bucketName - The Amazon Simple Storage Service (Amazon S3) bucket name that contains the ZIP or JAR used for the Lambda function's code.
updatedBucketName - The Amazon S3 bucket name that contains the .zip or .jar used to update the Lambda function's code.
key - The Amazon S3 key name that represents the .zip or .jar file (for example, LambdaHello-1.0-SNAPSHOT.jar).
"""
if (args.size != 6) {
println(usage)
exitProcess(1)
}
val functionName = args[0]
val role = args[1]
val handler = args[2]
val bucketName = args[3]
val updatedBucketName = args[4]
val key = args[5]
println("Creating a Lambda function named $functionName.")
val funArn = createScFunction(functionName, bucketName, key, handler, role)
println("The AWS Lambda ARN is $funArn")
// Get a specific Lambda function.
println("Getting the $functionName AWS Lambda function.")
getFunction(functionName)
// List the Lambda functions.
println("Listing all AWS Lambda functions.")
listFunctionsSc()
// Invoke the Lambda function.
println("*** Invoke the Lambda function.")
invokeFunctionSc(functionName)
// Update the AWS Lambda function code.
println("*** Update the Lambda function code.")
updateFunctionCode(functionName, updatedBucketName, key)
// println("*** Invoke the function again after updating the code.")
invokeFunctionSc(functionName)
// Update the AWS Lambda function configuration.
println("Update the run time of the function.")
updateFunctionConfiguration(functionName, handler)
// Delete the AWS Lambda function.
println("Delete the AWS Lambda function.")
delFunction(functionName)
}
suspend fun createScFunction(
myFunctionName: String,
s3BucketName: String,
myS3Key: String,
myHandler: String,
myRole: String,
): String {
val functionCode =
FunctionCode {
s3Bucket = s3BucketName
s3Key = myS3Key
}
val request =
CreateFunctionRequest {
functionName = myFunctionName
code = functionCode
description = "Created by the Lambda Kotlin API"
handler = myHandler
role = myRole
runtime = Runtime.Java17
}
// Create a Lambda function using a waiter
LambdaClient { region = "us-east-1" }.use { awsLambda ->
val functionResponse = awsLambda.createFunction(request)
awsLambda.waitUntilFunctionActive {
functionName = myFunctionName
}
return functionResponse.functionArn.toString()
}
}
suspend fun getFunction(functionNameVal: String) {
val functionRequest =
GetFunctionRequest {
functionName = functionNameVal
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
val response = awsLambda.getFunction(functionRequest)
println("The runtime of this Lambda function is ${response.configuration?.runtime}")
}
}
suspend fun listFunctionsSc() {
val request =
ListFunctionsRequest {
maxItems = 10
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
val response = awsLambda.listFunctions(request)
response.functions?.forEach { function ->
println("The function name is ${function.functionName}")
}
}
}
suspend fun invokeFunctionSc(functionNameVal: String) {
val json = """{"inputValue":"1000"}"""
val byteArray = json.trimIndent().encodeToByteArray()
val request =
InvokeRequest {
functionName = functionNameVal
payload = byteArray
logType = LogType.Tail
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
val res = awsLambda.invoke(request)
println("The function payload is ${res.payload?.toString(Charsets.UTF_8)}")
}
}
suspend fun updateFunctionCode(
functionNameVal: String?,
bucketName: String?,
key: String?,
) {
val functionCodeRequest =
UpdateFunctionCodeRequest {
functionName = functionNameVal
publish = true
s3Bucket = bucketName
s3Key = key
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
val response = awsLambda.updateFunctionCode(functionCodeRequest)
awsLambda.waitUntilFunctionUpdated {
functionName = functionNameVal
}
println("The last modified value is " + response.lastModified)
}
}
suspend fun updateFunctionConfiguration(
functionNameVal: String?,
handlerVal: String?,
) {
val configurationRequest =
UpdateFunctionConfigurationRequest {
functionName = functionNameVal
handler = handlerVal
runtime = Runtime.Java17
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
awsLambda.updateFunctionConfiguration(configurationRequest)
}
}
suspend fun delFunction(myFunctionName: String) {
val request =
DeleteFunctionRequest {
functionName = myFunctionName
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
awsLambda.deleteFunction(request)
println("$myFunctionName was deleted")
}
}
```
+ 有关 API 详细信息，请参阅《AWS SDK for Kotlin API Reference》**中的以下主题。
+ [CreateFunction](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [DeleteFunction](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [GetFunction](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Invoke](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [ListFunctions](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [UpdateFunctionCode](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [UpdateFunctionConfiguration](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
## 操作
### `CreateFunction`
以下代码示例演示了如何使用 `CreateFunction`。
**适用于 Kotlin 的 SDK**
还有更多相关信息 GitHub。在 [AWS 代码示例存储库](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/lambda#code-examples)中查找完整示例，了解如何进行设置和运行。
```
suspend fun createNewFunction(
myFunctionName: String,
s3BucketName: String,
myS3Key: String,
myHandler: String,
myRole: String,
): String? {
val functionCode =
FunctionCode {
s3Bucket = s3BucketName
s3Key = myS3Key
}
val request =
CreateFunctionRequest {
functionName = myFunctionName
code = functionCode
description = "Created by the Lambda Kotlin API"
handler = myHandler
role = myRole
runtime = Runtime.Java17
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
val functionResponse = awsLambda.createFunction(request)
awsLambda.waitUntilFunctionActive {
functionName = myFunctionName
}
return functionResponse.functionArn
}
}
```
+ 有关 API 的详细信息，请参阅适用[CreateFunction](https://sdk.amazonaws.com/kotlin/api/latest/index.html)于 K *otlin 的AWS SDK API 参考*。
### `DeleteFunction`
以下代码示例演示了如何使用 `DeleteFunction`。
**适用于 Kotlin 的 SDK**
还有更多相关信息 GitHub。在 [AWS 代码示例存储库](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/lambda#code-examples)中查找完整示例，了解如何进行设置和运行。
```
suspend fun delLambdaFunction(myFunctionName: String) {
val request =
DeleteFunctionRequest {
functionName = myFunctionName
}
LambdaClient { region = "us-east-1" }.use { awsLambda ->
awsLambda.deleteFunction(request)
println("$myFunctionName was deleted")
}
}
```
+ 有关 API 的详细信息，请参阅适用[DeleteFunction](https://sdk.amazonaws.com/kotlin/api/latest/index.html)于 K *otlin 的AWS SDK API 参考*。
### `Invoke`
以下代码示例演示了如何使用 `Invoke`。
**适用于 Kotlin 的 SDK**
还有更多相关信息 GitHub。在 [AWS 代码示例存储库](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/lambda#code-examples)中查找完整示例，了解如何进行设置和运行。
```
suspend fun invokeFunction(functionNameVal: String) {
val json = """{"inputValue":"1000"}"""
val byteArray = json.trimIndent().encodeToByteArray()
val request =
InvokeRequest {
functionName = functionNameVal
logType = LogType.Tail
payload = byteArray
}
LambdaClient { region = "us-west-2" }.use { awsLambda ->
val res = awsLambda.invoke(request)
println("${res.payload?.toString(Charsets.UTF_8)}")
println("The log result is ${res.logResult}")
}
}
```
+ 有关 API 详细信息，请参阅《AWS SDK for Kotlin API 参考》**中的 [Invoke](https://sdk.amazonaws.com/kotlin/api/latest/index.html)。
## 场景
### 创建无服务器应用程序来管理照片
以下代码示例演示如何创建无服务器应用程序，让用户能够使用标签管理照片。
**适用于 Kotlin 的 SDK**
演示如何开发照片资产管理应用程序，该应用程序使用 Amazon Rekognition 检测图像中的标签并将其存储以供日后检索。
有关如何设置和运行的完整源代码和说明，请参阅上的完整示例[ GitHub](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/usecases/creating_pam)。
要深入了解这个例子的起源，请参阅 [AWS 社区](https://community.aws/posts/cloud-journeys/01-serverless-image-recognition-app)上的博文。
**本示例中使用的服务**
+ API Gateway
+ DynamoDB
+ Lambda
+ Amazon Rekognition
+ Amazon S3
+ Amazon SNS