aws(学习笔记第三十九课) iotcore(Internet Of Thing)

• 使用iotcore

学习内容：

• 使用iotcore
• 学会使用CA证书

---

1. 整体架构

1.1 代码链接

• 代码链接(cdk_iot_thing)

1.2 整体架构（概要）

1.3 整体架构（详细 ）

• 创建AWS IOT things。
• 定义customResource，用来执行lambda，创建AWS IOT的certificate和private key。
• lambda里面，同时将创建的certificate和private key存储到AWS Secret Manager。
• 定义CdkIOTCloudWatchAccessRole，用于赋予权限给topicRule，能够将收到的IOT Message转发到CloudWatch。
• 创建topicRule，可以将AWS things接受的message发送到CloudWatch。

2. 代码解析

2.1 创建IOT thing

  # Environment variablesaccount=Aws.ACCOUNT_IDregion=Aws.REGIONiot_thing_name="CdkThing001"# Create an IoT Thingcfn_thing=iot.CfnThing(self, "MyCdkThing",thing_name=iot_thing_name)

这里，创建IOT thing，但是topic不需要特别创建。

2.2 创建AWS IOT certificate证书

2.2.1 创建lambda需要的role

这里采用customResource->lambda的方式，所以提前创建lambda执行需要的role。

    # Lambda role for creating certs and keyslambda_role = iam.Role(self, f"{iot_thing_name}LambdaRole", assumed_by=iam.ServicePrincipal("lambda.amazonaws.com"))lambda_role.add_to_policy(iam.PolicyStatement(actions=["secretsmanager:CreateSecret","secretsmanager:DeleteSecret"],resources=["arn:aws:secretsmanager:*:*:secret:*"]))lambda_role.add_to_policy(iam.PolicyStatement(actions=["iot:CreateKeysAndCertificate", "iot:UpdateCertificate"],resources=["*"]))

可以，看出，ServicePrincipal是lambda.amazonaws.com，policy都是和创建iot certificate证书相关的设定。

2.2.2 创建lambda

 # Custom Lambda to create IoT certificate and storing in secrets managercert_lambda = _lambda.Function(self,"CertHandler",function_name="CertHandlerFunction",runtime=_lambda.Runtime.PYTHON_3_11,code=_lambda.Code.from_asset("lambda"),handler="cert_handler.lambda_handler",role=lambda_role,log_retention=logs.RetentionDays.ONE_DAY,timeout=Duration.seconds(60))

2.2.3 lambda的函数处理

def on_create(event):response = iot.create_keys_and_certificate(setAsActive=True)certificate_id = response['certificateId']certificate_pem = response['certificatePem']key_pair = response['keyPair']if not certificate_id or not certificate_pem or not key_pair:raise ValueError('Faile