如何通过Python Lambda函数获取AWS IoT Core中指定事物组的所有事物名称

嘿，这个问题我之前做IoT项目时也踩过坑！Boto3确实没有提供一个直接返回事物组内所有事物名称的单一API，但咱们可以通过组合API并处理分页来实现，在Lambda环境里跑完全没问题~

第一步：确保Lambda拥有正确的IAM权限 #

首先得给Lambda的执行角色加上对应的IoT权限，不然会触发权限报错。你需要添加一条包含iot:ListThingsInThingGroup操作的IAM策略，示例策略如下：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "iot:ListThingsInThingGroup",
            "Resource": "arn:aws:iot:你的区域ID:你的AWS账号ID:thinggroup/目标事物组名称"
        }
    ]
}

如果需要访问多个事物组，也可以用通配符*替代具体的事物组名称，但建议遵循最小权限原则，只开放必要的资源权限。

第二步：编写Lambda的Python代码实现 #

核心思路是调用boto3.client('iot')的list_things_in_thing_group方法，这个API会返回组内的事物数据，但默认一次最多返回100条。如果你的事物组内有超过100个事物，就需要通过nextToken参数循环处理分页，直到获取到所有数据。

完整的Lambda handler代码示例：

import boto3

def lambda_handler(event, context):
    # 初始化AWS IoT客户端
    iot_client = boto3.client('iot')
    # 替换成你要查询的目标事物组名称
    target_group = "your-target-thing-group"
    thing_name_list = []
    next_token = None

    try:
        # 循环处理分页逻辑，直到没有下一页数据
        while True:
            # 构造请求参数，存在nextToken时携带
            request_args = {
                'thingGroupName': target_group
            }
            if next_token:
                request_args['nextToken'] = next_token
            
            # 调用API获取组内事物数据
            api_response = iot_client.list_things_in_thing_group(**request_args)
            # 提取当前页的事物名称并追加到列表
            thing_name_list.extend([item['thingName'] for item in api_response['things']])
            
            # 检查是否存在下一页的token，无则退出循环
            next_token = api_response.get('nextToken')
            if not next_token:
                break
        
        # 这里可以根据需求返回结果或做后续业务处理
        print(f"成功获取事物组内的所有事物：{thing_name_list}")
        return {
            'statusCode': 200,
            'body': thing_name_list
        }
    except Exception as error:
        print(f"查询过程中出现错误：{str(error)}")
        return {
            'statusCode': 500,
            'body': f"查询失败：{str(error)}"
        }

额外的实用提示 #

• 如果你的事物组是嵌套结构（父组包含子组），上面的代码只会返回直接属于目标组的事物，不会递归获取子组内的事物。如果需要递归查询，你可以额外调用list_thing_groups_for_parentAPI获取所有子组，再递归执行上述查询逻辑。
• Lambda的官方Python运行时（如3.8、3.9、3.10版本）都自带了最新版的boto3库，不需要你额外打包上传依赖。
• 测试阶段建议先用包含少量事物的测试组验证代码逻辑，确保权限和分页处理都正常。

内容来源于stack exchange