1 Resposta
- Mais recentes
- Mais votos
- Mais comentários
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不涉及该流程。
Conteúdo relevante
- AWS OFICIALAtualizada há 3 anos
- AWS OFICIALAtualizada há um ano
- AWS OFICIALAtualizada há um ano
- AWS OFICIALAtualizada há um ano