教程：在 Amazon MWAA 上自动管理您自己的环境终端节点

下载Amazon CloudFormation模板，然后解压缩.yml文件。

在新的命令提示符窗口中，导航到保存模板的文件夹，然后使用create-stack创建堆栈。该--template-body标志指定模板的路径。

$ aws cloudformation create-stack --stack-name stack-name --template-body file://cfn-vpc-private-network.yml

下载 Python 函数代码。

下载 IAM 权限策略，然后解压缩文件。

打开命令提示符，然后导航到保存 JSON 权限策略的文件夹。使用 IAM create-role命令创建新角色。

$ aws iam create-role --role-name function-role \
--assume-role-policy-document file://lambda-mwaa-vpce-policy.json

记下响应中的角色 ARN。Amazon CLI在下一步中，我们将使用函数的 ARN 将这个新角色指定为函数的执行角色。

导航到保存函数代码的文件夹，然后使用create-function命令创建新函数。

$ aws lambda create-function --function-name mwaa-vpce-lambda \
--zip-file file://mwaa-lambda-shared-vpc.zip --runtime python3.8 --role arn:aws:iam::123456789012:role/function-role --handler lambda_handler

请注意响应中的函数 ARN。Amazon CLI在下一步中，我们将指定 ARN 以将该函数配置为新 EventBridge 规则的目标。

使用 EventBridge put-rule命令创建新 EventBridge 规则。

$ aws events put-rule --name "mwaa-lambda-rule" \
--event-pattern "{\"source\":[\"aws.airflow\"],\"detail-type\":[\"MWAA Environment Status Change\"]}"

事件模式用于监听 Amazon MWAA 在环境状态发生变化时发送的通知。

{
  "source": ["aws.airflow"],
  "detail-type": ["MWAA Environment Status Change"]
}

使用put-targets命令将 Lambda 函数添加为新规则的目标。

$ aws events put-targets --rule "mwaa-lambda-rule" \
--targets "Id"="1","Arn"="arn:aws::lambda:region:123456789012:function:mwaa-vpce-lambda"

打开 Amazon MWAA 控制台，然后选择创建环境。

在 “名称” 中输入一个唯一的名称。

对于 Airflow 版本，请选择最新版本。

选择用于环境的 A mazon S3 存储桶和 DA dags/G 文件夹，然后选择 “下一步”。

在 “配置高级设置” 页面上，执行以下操作：

1. 对于虚拟私有云，请选择您在上一步中创建的 Amazon VPC。

2. 要访问 Web 服务器，请选择公共网络（可访问互联网）。

3. 对于安全组，请选择您创建的安全组Amazon CloudFormation。由于前面步骤中Amazon PrivateLink终端节点的安全组是自引用的，因此您必须为您的环境选择相同的安全组。

4. 对于端点管理，请选择客户管理的端点。

保留其余的默认设置，然后选择 “下一步”。

查看您的选择，然后选择创建环境。