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不涉及该流程。
관련 콘텐츠
- 질문됨 17일 전
- AWS 공식업데이트됨 3년 전
- AWS 공식업데이트됨 4년 전
- AWS 공식업데이트됨 2년 전
- AWS 공식업데이트됨 4년 전