AWS IoT Greengrass Version 1 2023 年 6 月 30 日进入延长寿命阶段。有关更多信息，请参阅 AWS IoT Greengrass V1 维护策略。在此日期之后，将 AWS IoT Greengrass V1 不会发布提供功能、增强功能、错误修复或安全补丁的更新。在上面运行的设备 AWS IoT Greengrass V1 不会中断，将继续运行并连接到云端。我们强烈建议您迁移到 AWS IoT Greengrass Version 2，这样可以添加重要的新功能并支持其他平台。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

SNS 连接器

SNS 连接器将消息发布到 Amazon SNS 主题。这使 Web 服务器、电子邮件地址和其他消息订阅者能够响应 Greengrass 组中的事件。

该连接器接收关于 MQTT 主题的 SNS 消息信息，然后将消息发送到指定的 SNS 主题。您可以视情况使用自定义 Lambda 函数对消息实施筛选或格式化逻辑，然后再将消息发布到该连接器。

此连接器具有以下版本。

有关版本更改的信息，请参阅更改日志。

要求

此连接器具有以下要求：

Version 3 - 4

• AWS IoT Greengrass Core 软件 v1.9.3 版或更高版本。

• Python 版本 3.7 或 3.8 已安装在核心设备上，并已添加到 PATH 环境变量中。

  注意

  要使用 Python 3.8，请运行以下命令来创建从默认 Python 3.7 安装文件夹到已安装的 Python 3.8 二进制文件的符号链接。

  sudo ln -s path-to-python-3.8/python3.8 /usr/bin/python3.7

  这会将设备配置为满足 AWS IoT Greengrass 的 Python 要求。

• 配置的 SNS 主题。有关更多信息，请参阅 Amazon Simple Notification Service 开发人员指南中的创建 Amazon SNS 主题。

• Greengrass 组角色，配置为允许对目标 Amazon SNS 主题执行 sns:Publish 操作，如以下示例 IAM policy 中所示。

  {
      "Version":"2012-10-17",
      "Statement":[
          {
              "Sid":"Stmt1528133056761",
              "Action":[
                  "sns:Publish"
              ],
              "Effect":"Allow",
              "Resource":[
                  "arn:aws:sns:region:account-id:topic-name"
              ]
          }
      ]
   }

  利用该连接器，您可以动态覆盖输入消息负载中的默认主题。如果您的实施使用此功能，IAM policy 必须允许对所有目标主题的 sns:Publish 权限。您可以授予对资源的具体或条件访问权限（例如，通过使用通配符*命名方案）。

  对于组角色要求，您必须将角色配置为授予所需权限，并确保角色已添加到组中。有关更多信息，请参阅管理 Greengrass 组角色（控制台）或管理 Greengrass 组角色 (CLI)。

Versions 1 - 2

• AWS IoT Greengrass Core 软件 v1.7 版或更高版本。

• Python 版本 2.7 已安装在核心设备上，并已添加到 PATH 环境变量中。

• 配置的 SNS 主题。有关更多信息，请参阅 Amazon Simple Notification Service 开发人员指南中的创建 Amazon SNS 主题。

• Greengrass 组角色，配置为允许对目标 Amazon SNS 主题执行 sns:Publish 操作，如以下示例 IAM policy 中所示。

  {
      "Version":"2012-10-17",
      "Statement":[
          {
              "Sid":"Stmt1528133056761",
              "Action":[
                  "sns:Publish"
              ],
              "Effect":"Allow",
              "Resource":[
                  "arn:aws:sns:region:account-id:topic-name"
              ]
          }
      ]
   }

  利用该连接器，您可以动态覆盖输入消息负载中的默认主题。如果您的实施使用此功能，IAM policy 必须允许对所有目标主题的 sns:Publish 权限。您可以授予对资源的具体或条件访问权限（例如，通过使用通配符*命名方案）。

  对于组角色要求，您必须将角色配置为授予所需权限，并确保角色已添加到组中。有关更多信息，请参阅管理 Greengrass 组角色（控制台）或管理 Greengrass 组角色 (CLI)。

连接器参数

该连接器提供以下参数：

Version 4

DefaultSNSArn

要将消息发布到的默认 SNS 主题的 ARN。目标主题可由输入消息负载中的 sns_topic_arn 属性覆盖。

注意

该组角色必须允许对所有目标主题的 sns:Publish 权限。有关更多信息，请参阅 要求。

在 AWS IoT 控制台中显示名称：默认 SNS 主题 ARN

必需：true

类型：string

有效模式：arn:aws:sns:([a-z]{2}-[a-z]+-\d{1}):(\d{12}):([a-zA-Z0-9-_]+)$

IsolationMode

此连接器的容器化模式。默认值为 GreengrassContainer，这意味着连接器在 AWS IoT Greengrass 容器内的隔离运行时环境中运行。

注意

组的默认容器化设置不适用于连接器。

AWS IoT 控制台中的显示名称：容器隔离模式

必需：false

类型：string

有效值：GreengrassContainer 或 NoContainer

有效模式：^NoContainer$|^GreengrassContainer$

Versions 1 - 3

DefaultSNSArn

要将消息发布到的默认 SNS 主题的 ARN。目标主题可由输入消息负载中的 sns_topic_arn 属性覆盖。

注意

该组角色必须允许对所有目标主题的 sns:Publish 权限。有关更多信息，请参阅 要求。

在 AWS IoT 控制台中显示名称：默认 SNS 主题 ARN

必需：true

类型：string

有效模式：arn:aws:sns:([a-z]{2}-[a-z]+-\d{1}):(\d{12}):([a-zA-Z0-9-_]+)$

创建连接器示例 (AWS CLI)

以下 CLI 命令创建一个 ConnectorDefinition，其初始版本包含 SNS 连接器。

aws greengrass create-connector-definition --name MyGreengrassConnectors --initial-version '{
    "Connectors": [
        {
            "Id": "MySNSConnector",
            "ConnectorArn": "arn:aws:greengrass:region::/connectors/SNS/versions/4",
            "Parameters": {
                "DefaultSNSArn": "arn:aws:sns:region:account-id:topic-name",
                "IsolationMode" : "GreengrassContainer"
            }
        }
    ]
}'

在 AWS IoT Greengrass 控制台中，您可以从组的连接器页面添加连接器。有关更多信息，请参阅 Greengrass 连接器入门（控制台）。

输入数据

此连接器接受关于 MQTT 主题的 SNS 消息信息，然后将信息按原样发布到目标 SNS 主题。输入消息必须采用 JSON 格式。

输出数据

此连接器将状态信息发布为 MQTT 主题的输出数据。

用法示例

使用以下概括步骤设置可用于尝试连接器的示例 Python 3.7 Lambda 函数。

示例

以下示例 Lambda 函数向连接器发送一条输入消息。

import greengrasssdk
import time
import json

iot_client = greengrasssdk.client('iot-data')
send_topic = 'sns/message'

def create_request_with_all_fields():
    return  {
        "request": {
            "message": "Message from SNS Connector Test"
        },
        "id" : "req_123"
    }

def publish_basic_message():
    messageToPublish = create_request_with_all_fields()
    print("Message To Publish: ", messageToPublish)
    iot_client.publish(topic=send_topic,
        payload=json.dumps(messageToPublish))

publish_basic_message()

def lambda_handler(event, context):
    return

许可证

SNS 连接器包含以下第三方软件/许可：

该连接器在 Greengrass Core 软件许可协议下发布。

更改日志

下表介绍每个版本连接器的更改。

Greengrass 组在一个时间上只能包含一个版本的连接器。有关升级连接器版本的信息，请参阅升级连接器版本。

另请参阅