首页 > 解决方案 > Lambda 读取 DynamoDB 并发送到 ML Endpoint

问题描述

背景:

我有一个列的“TimeStamp | Data1 | Data2”的 DynamoDB 表。我在 SageMaker 中还有一个 ML 端点,它需要 Data1 和 Data2 来生成一个输出值(分数)。

问题:

我的目标是编写一个 Lambda 函数(Java 或 Python)脚本来读取 DynamoDB 表中的最新行,然后通过 Endpoint 发送它并接收分数。

我试过的:

我只找到了通过将整个 DynamoDB 表导出到 s3 并在 Data Pipeline 中将其发送到端点来执行此操作的指南。这不是我想要的工作方式!

标签: amazon-web-servicesaws-lambdaamazon-sagemaker

解决方案


我是 Sagemaker 团队的工程师。

据我了解,您想使用 Lambda 函数

  1. 监听 DynamoDB 表更新

  2. 调用 Sagemaker 端点进行实时预测。

对于 (1),DynamoDB 流可能是一个很好的起点。这是使用 Lambda 函数处理 DynamoDB 流的教程:

对于 (2),这里是调用 Sagemaker 端点以在 Lambda 函数中进行预测的分步教程

希望这可以帮助。


推荐阅读