我想从 python 中的 dynamodb 流中读取数据,到目前为止我发现的替代方法是
使用 dynamodb 流低级库函数(如此处所述):然而,此解决方案似乎几乎不可能在生产环境中维护,应用程序必须维护分片的状态等。
使用为读取 Kinesis 流而设计的KCL 库:该库的 python 版本似乎无法从 dynamodb 流中读取。
在 python 中成功处理 dynamodb 流的选项有哪些?(可能示例的链接将非常有帮助)
PS:我考虑过使用 lambda 函数来处理 dynamodb,但对于这个任务,我想在应用程序中读取流,因为它必须与无法通过 lamda 函数完成的其他组件交互。