Greengrass 连接器入门 (CLI)

首先，创建该密钥。

aws secretsmanager create-secret --name greengrass-TwilioAuthToken --secret-string twilio-auth-token

从输出中复制该密钥的 ARN。您将使用此密钥创建并配置 Twilio 通知连接器。

创建一个包含初始版本的资源定义。

从输出中复制该资源定义的 LatestVersionArn。您将使用此值向部署到核心的组版本添加资源定义版本。

创建包含初始版本的连接器定义。

从输出中复制该连接器定义的 LatestVersionArn。您将使用此值向部署到核心的组版本添加连接器定义版本。

从 AWS IoT Greengrass Core 软件开发工具包下载页面，将适用于 Python 的 AWS IoT Greengrass Core 软件开发工具包下载到您的计算机上。

解压缩下载的程序包以获取软件开发工具包。软件开发工具包是 greengrasssdk 文件夹。

将以下 Python 代码函数保存在名为 temp_monitor.py 的本地文件中。

import greengrasssdk
import json
import random

client = greengrasssdk.client('iot-data')

# publish to the Twilio Notifications connector through the twilio/txt topic
def function_handler(event, context):
    temp = event['temperature']
    
    # check the temperature
    # if greater than 30C, send a notification
    if temp > 30:
        data = build_request(event)
        client.publish(topic='twilio/txt', payload=json.dumps(data))
        print('published:' + str(data))
        
    print('temperature:' + str(temp))
    return

# build the Twilio request from the input data
def build_request(event):
    to_name = event['to_name']
    to_number = event['to_number']
    temp_report = 'temperature:' + str(event['temperature'])

    return {
        "request": {
            "recipient": {
                "name": to_name,
                "phone_number": to_number,
                "message": temp_report
            }
        },
        "id": "request_" + str(random.randint(1,101))
    }

将以下项目压缩到名为 temp_monitor_python.zip 的文件中。在创建 ZIP 文件时，仅包含代码和依赖项，而不包含文件夹。

此即 Lambda 函数部署程序包。

创建 IAM 角色，以便您可以在创建该函数时传入角色 ARN。

从输出中复制 Arn。

使用 AWS Lambda API 创建 TempMonitor 函数。以下命令假定该 zip 文件位于当前目录中。

aws lambda create-function \
--function-name TempMonitor \
--zip-file fileb://temp_monitor_python.zip \
--role role-arn \
--handler temp_monitor.function_handler \
--runtime python3.7

发布该函数的版本。

aws lambda publish-version --function-name TempMonitor --description 'First version'

为发布的版本创建别名。

Greengrass 组可以按别名（推荐）或版本引用 Lambda 函数。使用别名，您可以更轻松地管理代码更新，因为您在更新函数代码时，不必更改订阅表或组定义。相反，您只需将别名指向新的函数版本。

aws lambda create-alias --function-name TempMonitor --name GG_TempMonitor --function-version 1

从输出中复制 AliasArn。在为 AWS IoT Greengrass 配置函数时以及在创建订阅时，使用此值。

创建一个包含初始版本的函数定义。

从输出中复制 LatestVersionArn。您将使用此值向部署到核心的组版本添加函数定义版本。

从输出中复制 Id。您在稍后更新该函数时将使用此值。

创建一个订阅定义，其中包含带有订阅的初始版本。

从输出中复制 LatestVersionArn。您将使用此值向部署到核心的组版本添加订阅定义版本。

获取组的 ID 和最新组版本：

1. 获取目标 Greengrass 组和组版本的 ID。此过程假定这是最新的组和组版本。以下查询将返回最近创建的组。

   aws greengrass list-groups --query "reverse(sort_by(Groups, &CreationTimestamp))[0]"

   或者，您也可以按名称查询。系统不要求组名称是唯一的，所以可能会返回多个组。

   aws greengrass list-groups --query "Groups[?Name=='MyGroup']"

   注意

   您还可以在 AWS IoT 控制台中找到这些值。组 ID 显示在组的设置页面上。组版本 ID 显示在组的部署选项卡上。

2. 从输出中复制目标组的 Id。您将使用此值获取核心定义版本及部署组的时间。

3. 从输出中复制 LatestVersion，这是添加到组的最后一个版本的 ID。您将使用此值获取核心定义版本。

获取核心定义版本的 ARN：

1. 获取组版本。在此步骤中，我们假定最新组版本包含一个核心定义版本。

   • 使用为组复制的 替换 group-idId。

   • 使用为组复制的 LatestVersion 替换 group-version-id。

   aws greengrass get-group-version \
   --group-id group-id \
   --group-version-id group-version-id

2. 从输出中复制 CoreDefinitionVersionArn。

创建组版本。

aws greengrass create-group-version \
--group-id group-id \
--core-definition-version-arn core-definition-version-arn \
--resource-definition-version-arn resource-definition-version-arn \
--connector-definition-version-arn connector-definition-version-arn \
--function-definition-version-arn function-definition-version-arn \
--subscription-definition-version-arn subscription-definition-version-arn

从输出中复制 Version 的值。这是组版本的 ID。您将使用此值部署组版本。

在核心设备终端中，确保 AWS IoT Greengrass 守护程序正在运行。

1. 要检查进程守护程序是否正在运行，请执行以下操作：

   ps aux | grep -E 'greengrass.*daemon'

   如果输出包含 root 的 /greengrass/ggc/packages/1.11.6/bin/daemon 条目，则表示进程守护程序正在运行。

2. 启动进程守护程序：

   cd /greengrass/ggc/core/
   sudo ./greengrassd start

创建 部署。

aws greengrass create-deployment \
--deployment-type NewDeployment \
--group-id group-id \
--group-version-id group-version-id

从输出中复制 DeploymentId。

获取部署状态。

aws greengrass get-deployment-status \
--group-id group-id \
--deployment-id deployment-id

如果状态为 Success，则部署成功。有关问题排查帮助，请参阅故障排除 AWS IoT Greengrass。

在 AWS IoT 控制台主页上，选择测试。

对于订阅主题，请使用以下值，然后选择订阅。Twilio 通知连接器向此主题发布状态信息。

对于发布到主题，请使用以下值，然后选择发布 来调用函数。

{
   "to_name": "recipient-name",
   "to_number": "recipient-phone-number",
   "temperature": 31
}

如果成功，收件人将收到短信，控制台将在输出数据中显示 success 状态。

现在，将输入消息中的 temperature 更改为 29 并发布。由于温度小于 30，因此 TempMonitor 函数不会触发 Twilio 消息。