微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

通过 AWS lambda 查询和更新 Redshift

如何解决通过 AWS lambda 查询和更新 Redshift

我正在使用 step 函数,它将 JSON 作为 event(来自 s3 上传的对象数据)提供给 Lambda。我必须检查 JSON 并将其中的 2 个值(文件名和 eTag)与我的 redshift 数据库中的数据进行比较。如果该条目不存在,我必须将文件分类到不同的存储桶,并将条目添加到 redshift DB(版本控制)。问题是,我不太清楚如何通过 Lambda 查询和更新 Redshift。有人可以就我应该采用的方法提出建议吗?谢谢!

编辑:应该提到 lambda 是在 Python 中

解决方法

实现此用例的一种方法是您可以使用 Java 运行时 API 编写 Lambda 函数,然后在 Lambda 函数中使用 RedshiftDataClient 对象。使用此 API,您可以在 Redshift 集群上执行 CRUD 操作。

查看示例:

https://github.com/awsdocs/aws-doc-sdk-examples/tree/master/javav2/example_code/redshift/src/main/java/com/example/redshiftdata

如果您不确定如何使用可调用 AWS 服务的 Lambda Java 运行时 API 构建 Lambda 函数,请参阅:

Creating an AWS Lambda function that detects images with Personal Protective Equipment

此示例向您展示如何使用调用 AWS 服务的 Java 运行时 API 开发 Lambda 函数。因此,不要调用 Amazon S3 或 Rekognition,而是使用 Lambda 函数中的 RedshiftDataClient 来执行 Redshift CRUD 操作。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。