如何修改Lambda使用AWS IoT Data的Client ID以避免设备断开？

配置AWS IoT规则：当数据发布到主题topic/type/<clientId>/data时触发Lambda函数。Lambda从DynamoDB取数后，将结果发布到topic/type/<clientId>/getData。现有设备使用<clientId>作为客户端ID，每当Lambda触发时，设备就会断开连接。推测Lambda发布消息时使用了和设备相同的<clientId>，但断开原因未显示“重复客户端ID”，需修改Lambda通过IoT Data发布数据时的客户端ID。

注：将<clientId>改为IoT Thing客户端ID以外的值时，设备不会断开连接。流程：设备发布到topic/type/<clientId>/data → IoT规则触发Lambda → Lambda处理后发布到topic/type/<clientId>/getData

相关代码（index.js） #

const AWS = require('aws-sdk');
const dynamo = new AWS.DynamoDB.DocumentClient();
const iot = new AWS.IotData({endpoint : 'XXXXXXXXXXXXXXXXX.iot.XX-XXXXXXX-X.amazonaws.com'});
exports.handler = async (event) => {

//从DynamoDB获取数据及其他处理逻辑

 var iotparams = {
            topic : "topic/"+deviceInfo.Item.deviceType+"/"+event.deviceId+"/getProfile",
            payload : JSON.stringify(profile.Item)
        };
        await iot.publish(iotparams).promise();

...

}

测试事件JSON #

{
  "tableName": "mytableName",
  "id": <clientId>
}

默认情况下，Lambda使用AWS.IotData的publish方法（REST API）发布消息时，客户端ID由AWS IoT服务自动分配，并非设备的<clientId>，但仍可能存在其他关联导致设备断开。要自定义Lambda发布消息时的客户端ID，需改用MQTT客户端通过WebSocket连接AWS IoT，手动指定客户端ID：

1. 添加依赖：在Lambda部署包或Lambda层中包含mqtt.js库。
2. 修改代码：使用MQTT客户端连接到AWS IoT WebSocket端点，指定自定义客户端ID（避免与设备的<clientId>冲突，例如lambda-publisher-${deviceId}），然后发布消息。
3. 权限配置：确保Lambda的IAM角色拥有iot:Connect和iot:Publish权限。

修改后的代码示例：

const AWS = require('aws-sdk');
const mqtt = require('mqtt');
const dynamo = new AWS.DynamoDB.DocumentClient();

exports.handler = async (event) => {
  // 原有DynamoDB数据获取及处理逻辑
  const deviceId = event.deviceId;
  const deviceType = deviceInfo.Item.deviceType;
  const payload = JSON.stringify(profile.Item);

  // AWS IoT WebSocket端点
  const endpoint = 'wss://XXXXXXXXXXXXXXXXX.iot.XX-XXXXXXX-X.amazonaws.com/mqtt';
  // 自定义客户端ID，避免与设备ID冲突
  const clientId = `lambda-publisher-${deviceId}`;

  // 获取AWS凭证并生成MQTT连接签名
  const credentials = await AWS.config.credentials.getPromise();
  const dateStamp = credentials.expiration.toISOString().split('T')[0];
  const amzDate = credentials.expiration.toISOString().replace(/[:-]/g, '');
  const credential = encodeURIComponent(`${credentials.accessKeyId}/${dateStamp}/${AWS.config.region}/iotdevicegateway/aws4_request`);

  const options = {
    clientId: clientId,
    username: `?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=${credential}&X-Amz-Date=${amzDate}&X-Amz-SignedHeaders=host&X-Amz-Signature=${credentials.signature}`,
    password: '',
    clean: true,
    reconnectPeriod: 0 // Lambda短运行时，无需重连
  };

  // 连接MQTT并发布消息
  return new Promise((resolve, reject) => {
    const client = mqtt.connect(endpoint, options);
    client.on('connect', () => {
      client.publish(`topic/${deviceType}/${deviceId}/getProfile`, payload, (err) => {
        client.end();
        err ? reject(err) : resolve({statusCode: 200, body: '消息发布成功'});
      });
    });
    client.on('error', reject);
  });
};

另外，可通过以下方式确认设备断开的具体原因：

• 登录AWS IoT控制台，进入测试页面查看MQTT客户端连接状态
• 在CloudWatch日志中查找IoT设备的连接日志，确认断开原因是否为客户端ID重复

内容的提问来源于stack exchange，提问作者Nishuthan S