通过 QLDB 流从 AWS Kinesis 读取流数据时出现 Amazon.IonDotnet.Internals.Text.InvalidTokenException 错误

Question

我有一个正在运行的解决方案，在 AWS QLDB 上执行一些操作。所有工作负载均使用 .NET 开发。目前为止没问题...

现在我只是尝试传输 QLDB 数据。 QLDB 中的数据通过 AWS Kinesis 进行流式传输，作为 QLDB 的内置功能。

我正在尝试使用 .NET SDK 从 Kinesis Stream 读取数据。

当我读取数据流时，

IonLoader.Default.Load(record.Data)

我收到以下错误

Amazon.IonDotnet.Internals.Text.InvalidTokenException: Token � : 65533 is not expected

我随机收到此错误...不确定根本原因。

当我检查 Kinesis 中的流数据时，我注意到这种奇怪的模式。 我非常确定这些数据存在错误。

有什么建议会很好吗？

Answer 1

您可能已启用 Kinesis 记录聚合 ，因为它默认为 QLDB 流启用。

这个简短文档链接到几种语言的AWS实验室实现：https://github.com/awslabs/kinesis-aggregation。 C# 未实现，因此您必须自己实现 C# 解聚合器，或者在 QLDB 控制台中关闭流的记录聚合。