实现 C2C 连接器接口操作

的托管集成 AWS IoT Device Management 定义了您 AWS Lambda 必须处理的四个操作才有资格成为连接器。您的 C2C 连接器必须实现以下每项操作：

调用详情

的托管集成 AWS IoT Device Management 始终通过操作调用带有 JSON 字符串负载的 Lambda 函数。 AWS Lambda invokeFunction请求操作必须在每个请求负载中包含一个operationName字段。

调用设置：

实现示例

您为连接器实现的 Lambda 将解析请求有效负载operationName中的一个，并实现相应的功能以映射到第三方云：

public ConnectorResponse handleRequest(final ConnectorRequest request) 
        throws OperationFailedException {
    Operation operation;
    try {
        operation = Operation.valueOf(request.payload().operationName());
    } catch (IllegalArgumentException ex) {
        throw new ValidationException(
           "Unknown operation '%s'".formatted(request.payload().operationName()), 
           ex
        );
    }

    return switch (operation) {
        case ActivateUser -> activateUserManager.activateUser(request);
        case DiscoverDevices -> deviceDiscoveryManager.listDevices(request);
        case SendCommand -> sendCommandManager.sendCommand(request);
        case DeactivateUser -> deactivateUser.deactivateUser(request);
    };
}

请求格式示例

以下示例详细介绍了来自托管集成的通用连接器请求，其中包含每个必需接口的公共字段。从示例中，您可以看到既有请求标头，又有请求负载。请求标头在每个操作接口中都很常见。

OAuth 2.0 示例：

{
        "header": {
                "auth": { 
                        "token": "ashriu32yr97feqy7afsaf", 
                        "type": "OAuth2.0"
                }
        },
        "payload":{
                "operationName": "AWS.SendCommand",
                "operationVersion": "1.0",
                "connectorId": "exampleId",
        …
        }
}

通用授权示例：

{
        "header": {
                "auth": { 
                        "secretsManager": {
                                "arn": "string",
                                "versionId": "string"
                        },
                        "type": "GeneralAuthorization"
                }
        },
        "payload":{
                "operationName": "AWS.SendCommand",
                "operationVersion": "1.0",
                "connectorId": "exampleId",
        …
        }
}

默认请求标头

默认标题字段因授权类型而异。您的连接器必须同时处理 OAuth 2.0 和通用授权请求标头。

OAuth 2.0 默认标头：

{
    "header": {
        "auth": {
            "token": string,    // End user's Access Token
            "type": "OAuth2.0"
        }
    }
}

通用授权默认标头：

{
    "header": {
        "auth": {
            "secretsManager": {
                "arn": "string",
                "versionId": "string"
            },
            "type": "GeneralAuthorization"
        }
    }
}

请求有效负载

除了常用标头外，每个请求都将有一个有效负载。虽然此有效载荷对每种操作类型都有唯一的字段，但每个有效载荷都有一组默认字段，这些字段将始终存在。

默认响应标头

每项ACK操作都将通过 AWS IoT Device Management 的托管集成进行响应，确认您的 C2C 连接器已收到请求并开始处理请求。

{
 	"header":{
 		"responseCode": 200 
 	},
 	"payload":{
 		"responseMessage": “Example response!”
 	}
}

{
    "header": {
        "responseCode": Integer
    }
}

响应标头字段

在本文档中描述的各种连接器接口和 API 架构中，都有一个responseMessage或Message字段。这是一个可选字段，用于 C2C 连接器 Lambda 使用与请求及其执行有关的任何上下文进行响应。最好是，任何导致状态码之外的错误都200应包含描述错误的消息值。

使用 API 响应 C2C 连接器操作请求 SendConnectorEvent

的托管集成要求 AWS IoT Device Management 您的连接器在每个 and 操作中都以异步方式运行AWS.SendCommand。AWS.DiscoverDevices这意味着对这些操作的初始响应只是 “确认” 您的 C2C 连接器已收到请求。

使用 SendConnectorEvent API，您的连接器应发送以下列表中的事件类型，用于AWS.DiscoverDevices和AWS.SendCommand操作以及主动设备事件（例如手动开启和关闭灯光）。

工作流程示例

如果您的 C2C 连接器收到DiscoverDevices请求，则托管集成 AWS IoT Device Management 预计该请求：

SendConnectorEventAPI 调用可以在您有权访问 C2C 连接器 AWS 账户 Lambda 凭证的任何地方进行。在 AWS IoT Device Management 的托管集成收到此事件之前，设备发现流程才会成功。

SendConnectorEvent API

您的连接器调用此托管集成 AWS IoT Device Management API 来发送设备事件。仅接受 3 种类型的事件：