使用 AWS Lambda 作为任何 IoT 项目的数据处理。-Python教程-PHP中文网

使用 AWS Lambda 作为任何 IoT 项目的数据处理。

Mary-Kate Olsen

发布： 2024-12-21 04:13:10

原创

929 人浏览过

Using AWS Lambda as data processing for any IoT project.

要开始某件事，需要适当的计划和准备。当我选修一门叫做物联网的选修课时，我想到了这个想法。没教好？但这给了我这个想法。当您需要给植物浇水时，一个简单的湿度检查器可以为您提供最新信息。使用 Aws Lambda，我们可以使用他们的服务器，而不是使用笔记本电脑，并在可以用于其他用途时保持其长时间运行。

为什么选择 AWS Lambda？

成本：相当便宜，并且可以选择首次互动免费。因此，对于想要入门但资金紧张的人来说，AWS Lambda 是一个不错的选择。
实时处理：通过始终开启的服务器，它可以实时处理数据，根据接收到的数据执行操作，并发送通知。
可扩展性：随着时间的推移，如果您想增加这个项目，AWS Lambda 可以很好地扩展到您需要的任何内容。
与其他 AWS 服务集成：由于 AWS 提供了大量服务，因此它可以作为满足您需求的一站式商店。如果您正在寻找的服务已经在这里，则无需寻找其他地方。

物联网用例：温度监控？️

让我们想象一个湿度监测系统。传感器定期将数据发送到 AWS IoT Core，这会触发设置的 AWS Lambda 函数来处理数据并将其存储在 DynamoDB 中。 Lambda 函数还会向用户发送通知。

部署 IoT 项目的分步指南？

1) 设置 AWS IoT Core ?️

创建 IoT 事物：导航到 AWS IoT Core 控制台并定义您的 IoT 设备。
生成证书：下载设备证书和密钥以进行安全通信。
附加策略：授予您的 IoT 设备发布和订阅主题的权限。

2) 编写 Lambda 函数？
创建一个 Python 函数来处理传入的 IoT 数据：

import json
import boto3

def lambda_handler(event, context):
    # Parse the incoming event
    payload = json.loads(event['body'])
    temperature = payload['temperature']
    device_id = payload['device_id']

    # Store in DynamoDB
    dynamodb = boto3.client('dynamodb')
    dynamodb.put_item(
        TableName='TemperatureReadings',
        Item={
            'DeviceID': {'S': device_id},
            'Temperature': {'N': str(temperature)},
        }
    )

    # Send an alert if temperature exceeds threshold
    if temperature > 30:
        print(f"ALERT! High temperature: {temperature}°C")

    return {
        'statusCode': 200,
        'body': json.dumps('Data processed successfully!')
    }

登录后复制

3) 将 IoT Core 连接到 Lambda ？

创建规则：在 AWS IoT Core 中，创建一条规则来触发您的 Lambda 函数。
定义主题：指定您的设备发布到的 MQTT 主题（例如传感器/温度）。
添加操作：将规则链接到您的 Lambda 函数。

4) 部署 Lambda 函数？

将代码上传为 .zip 文件或使用 AWS 管理控制台中的内联代码编辑器。
设置必要的环境变量并从 IoT Core 配置触发器。

5) 测试您的设置？
从 IoT 设备向 MQTT 主题发布测试消息：

import json
import boto3

def lambda_handler(event, context):
    # Parse the incoming event
    payload = json.loads(event['body'])
    temperature = payload['temperature']
    device_id = payload['device_id']

    # Store in DynamoDB
    dynamodb = boto3.client('dynamodb')
    dynamodb.put_item(
        TableName='TemperatureReadings',
        Item={
            'DeviceID': {'S': device_id},
            'Temperature': {'N': str(temperature)},
        }
    )

    # Send an alert if temperature exceeds threshold
    if temperature > 30:
        print(f"ALERT! High temperature: {temperature}°C")

    return {
        'statusCode': 200,
        'body': json.dumps('Data processed successfully!')
    }

登录后复制