1 Answer
- Newest
- Most votes
- Most comments
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不涉及该流程。
Relevant content
- asked a year ago
- asked a year ago
- Accepted Answerasked 2 months ago
- AWS OFFICIALUpdated 3 years ago
- AWS OFFICIALUpdated 8 months ago
- AWS OFFICIALUpdated 6 months ago
- AWS OFFICIALUpdated a year ago