在使用 AWS Amplify PubSub 获取压缩二进制数据时,可能会出现“Malformed UTF数据”错误。这是因为默认情况下,AWS Amplify PubSub 将接收到的消息视为 UTF-8 编码的文本。
为了解决这个问题,您可以通过在订阅时配置消息处理程序来指定接收到的消息类型为二进制数据。以下是一个示例代码,演示了如何使用 AWS Amplify PubSub 接收压缩二进制数据并解压缩:
import { PubSub } from 'aws-amplify';
import { inflateRaw } from 'zlib';
const topicName = 'your-topic-name';
// 订阅消息并指定消息处理程序
PubSub.subscribe(topicName).subscribe({
next: async (data) => {
const message = JSON.parse(data.value);
const compressedData = Buffer.from(message.data, 'base64');
// 解压缩二进制数据
const uncompressedData = await inflateRaw(compressedData);
// 处理解压缩后的数据
console.log(uncompressedData.toString('utf-8'));
},
error: (error) => {
console.error('Error:', error);
},
complete: () => {
console.log('Subscription complete');
}
});
在上面的示例中,我们使用 PubSub.subscribe() 方法订阅特定的主题,并使用 next 回调来处理接收到的消息。我们首先将消息中的 base64 编码的数据转换为二进制数据,然后使用 zlib 模块的 inflateRaw() 方法对数据进行解压缩。最后,我们可以将解压缩后的数据转换为 UTF-8 编码的文本,并进行进一步处理。
请确保在使用示例代码之前,已经安装了 aws-amplify 和 zlib 模块,可以通过运行以下命令安装它们:
npm install aws-amplify zlib --save
这样,您就可以使用 AWS Amplify PubSub 获取压缩二进制数据并解压缩,避免了“Malformed UTF数据”错误。