CloudWatch Events触发Lambda修改RDS instance type 小结

待我称王封你为后i 2023-02-19 11:26 34阅读 0赞

1. 在实现之前，先了解下RDS都有哪些[实例类型][Link 1]吧。

2. 和我的另一篇[修改EC2实例类型][EC2]的文章一样，如果还没有具备本地开发Lambda的环境，先看看我的[这篇文章][Link 2]吧。

通过上面的小结，你已经具备了Lambda的开发环境。

3. 在实现CloudWatch Events触发Lambda之前，首先先讲讲如何**通过Lambda修改RDS实例类型**吧。

查了下资料，[官网][Link 3]只有简短的接口介绍，主要使用的是**ModifyDbInstanceRequest**，而其中的详细参数列表可以参考：[Request Parameters][]。

1) 首先是在本地测试暂停RDS实例和修改RDS实例类型。

a) 添加pom.xml依赖。

<dependency>
      <groupId>software.amazon.awssdk</groupId>
      <artifactId>rds</artifactId>
      <version>2.5.10</version>
    </dependency>

b) [创建一个RDS实例][RDS]，假设这里的DB Identifier是testIdentifier。

c) 测试启动实、暂停实例。

public static void startInstance(String identifier) {
    	RdsClient rdsClient = RdsClient.builder().region(Region.of("us-east-2")).build();
    
    	StartDbInstanceRequest request = StartDbInstanceRequest.builder().dbInstanceIdentifier(identifier).build();
    
    	rdsClient.startDBInstance(request);
    
    	System.out.printf("Successfully started instance %s", identifier);
    }
    
    public static void stopInstance(String identifier) {
    	RdsClient rdsClient = RdsClient.builder().region(Region.of("us-east-2")).build();
    
    	StopDbInstanceRequest request = StopDbInstanceRequest.builder().dbInstanceIdentifier(identifier).build();
    
    	rdsClient.stopDBInstance(request);
    
    	System.out.printf("Successfully stop instance %s", identifier);
    }

**注**：这里的启动和暂停实例都不会堵塞主线程，所以如果需启动后立刻执行后续操作，要注意休眠主线程等待实例重启成功。RDS实例启动和暂停一般需要5-10分钟。

d) 测试修改实例类型。

public static void modifyInstance(String identifier, String type) {
    	RdsClient rdsClient = RdsClient.builder().region(Region.of("us-east-2")).build();
    
    	ModifyDbInstanceRequest request = ModifyDbInstanceRequest.builder().dbInstanceIdentifier(identifier)
    			.dbInstanceClass(type).applyImmediately(true).build();
    
    	rdsClient.modifyDBInstance(request);
    
    	System.out.println();
    }

e) 测试demo的[源码下载][Link 4]。

2) 通过Lambda函数来实现暂停RDS和修改RDS 实例类型（修改实例类型需要在Available状态）。

@Override
    public String handleRequest(Map<String, String> event, Context context) {
    	context.getLogger().log("Received event: " + event);
    	String action = event.get("action");
    	String identifier = event.get("identifier");
    	
    	switch (action) {
    	case "start":
    		startInstance(identifier);
    		break;
    	case "stop":
    		stopInstance(identifier);
    		break;
    	case "modify":
    		String type = event.get("type");
    		modifyInstance(identifier, type);
    		break;
    	default:
    		break;
    	}
    	return "okokok okokok";
    }

**注**：这里的event将会从CloudWatch Event触发Lambda时传递过来。

3) 测试Lambda函数，现在的实例状态如图。

![20200620150532281.png][]

a) 创建Lambda test events，如图：

![20200620150233693.png][]

b) 测试modify流程。

作为测试，test event输入以下的json参数。

{
      "action": "modify",
      "identifier": "testidentifier",
      "type": "db.t2.small"
    }

此时的Status是Modifying，几分钟后实例类型就会修改成了db.t2.small。

![20200620151118983.png][]

然后，Status又会变成Available。

![20200620151836892.png][]

日志输出如下：

![20200620151802256.png][]

c) 测试stop流程。

test event输入以下的json参数。

{
      "action": "stop",
      "identifier": "testidentifier"
    }

此时的Status是Stopping。

![2020062015200563.png][]

大概十分钟左右的等待，Status才是Stopped。

![20200620152936727.png][]

4. [CloudWatch的Events][CloudWatch_Events]添加Rules。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70][]

Constant (JSON text)写入：\{   "action": "start",   "identifier": "testidentifier" \} 。

如图，这里[生成Cron表达式][Cron]指的是每小时触发Lambda以启动实例。

5. 假设创建了名为test-start的Rule，并且每次35分的时候都触发Lambda，如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 1][]

**附**：

1. [如何在 CloudWatch 中将计划触发器的参数传递到 AWS Batch 作业][CloudWatch _ AWS Batch]。

**注**：

1. 如果遇到：InvalidDbInstanceStateException: Cannot modify a stopped DB Instance (Service: Rds, Status Code: 400...

因为实例的Status不是Available的话，这时不能修改类型。

2. 在实例已启动时，再执行start命令，会导致：InvalidDbInstanceStateException: Instance termcondition is not stopped, cannot be started. (Service: Rds, Status Code: 400...

3. 如果在启动过程中就修改类型，会导致：InvalidDbInstanceStateException: Database instance is not in available state. (Service: Rds, Status Code: 400...

[Link 1]: https://aws.amazon.com/cn/rds/instance-types/
[EC2]: https://blog.csdn.net/BAStriver/article/details/106430889
[Link 2]: https://blog.csdn.net/BAStriver/article/details/105606281
[Link 3]: https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/rds/AmazonRDS.html#modifyDBInstance-com.amazonaws.services.rds.model.ModifyDBInstanceRequest-
[Request Parameters]: https://docs.aws.amazon.com/AmazonRDS/latest/APIReference/API_ModifyDBInstance.html
[RDS]: https://us-east-2.console.aws.amazon.com/rds/home?region=us-east-2#launch-dbinstance:gdb=false;s3-import=false
[Link 4]: https://download.csdn.net/download/BAStriver/12538284
[20200620150532281.png]: https://img-blog.csdnimg.cn/20200620150532281.png
[20200620150233693.png]: https://img-blog.csdnimg.cn/20200620150233693.png
[20200620151118983.png]: https://img-blog.csdnimg.cn/20200620151118983.png
[20200620151836892.png]: https://img-blog.csdnimg.cn/20200620151836892.png
[20200620151802256.png]: https://img-blog.csdnimg.cn/20200620151802256.png
[2020062015200563.png]: https://img-blog.csdnimg.cn/2020062015200563.png
[20200620152936727.png]: https://img-blog.csdnimg.cn/20200620152936727.png
[CloudWatch_Events]: https://us-east-2.console.aws.amazon.com/cloudwatch/home?region=us-east-2#rules:action=create
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200620152604402.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg==,size_16,color_FFFFFF,t_70
[Cron]: https://crontab-generator.org/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/2020062015321743.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg==,size_16,color_FFFFFF,t_70
[CloudWatch _ AWS Batch]: https://aws.amazon.com/cn/premiumsupport/knowledge-center/batch-parameters-trigger-cloudwatch/