1 回答
- 最新
- 投票最多
- 评论最多
0
【以下的回答经过翻译处理】 如果想在发送消息到Kinesis Data Streams之前添加附加数据,则需要将其作为JSON有效负载发送。因此,您的规则SQL将类似于:
SELECT encode(*, 'base64') AS data, principal() AS principal FROM 'topic/subtopic'
在处理流的Lambda函数中,您需要对“data”字段进行base64解码以恢复二进制有效负载,然后再解码protobuf。
除非Lambda函数使用它检索protobuf模式,否则Amazon S3不涉及该流程。
相关内容
- AWS 官方已更新 10 个月前
- AWS 官方已更新 3 年前
- AWS 官方已更新 1 年前
- AWS 官方已更新 3 年前