23

我想从 python 中的 dynamodb 流中读取数据,到目前为止我发现的替代方法是

  1. 使用 dynamodb 流低级库函数(如此处所述):然而,解决方案似乎几乎不可能在生产环境中维护,应用程序必须维护分片的状态等。

  2. 使用为读取 Kinesis 流而设计的KCL 库:该库的 python 版本似乎无法从 dynamodb 流中读取。

在 python 中成功处理 dynamodb 流的选项有哪些?(可能示例的链接将非常有帮助)

PS:我考虑过使用 lambda 函数来处理 dynamodb,但对于这个任务,我想在应用程序中读取流,因为它必须与无法通过 lamda 函数完成的其他组件交互。

4

1 回答 1

1

我仍然建议使用 lambda。设置非常简单且非常健壮(很容易管理重试、批处理、停机时间......)

然后从您的 lambda 调用中,您可以轻松地以方便的方式将您的数据发送到您现有的程序(包括但不限于:SNS、SQS、自定义服务器 webhook、将数据发送到您拥有的自定义发布/订阅服务.. 。ETC)

于 2021-08-08T08:38:25.600 回答