我希望能够根据数据内容将数据发送到Kinesis Firehose。例如,如果我发送以下JSON数据:
{
"name": "John",
"id": 345
}
我希望根据ID过滤数据并将其发送到S3桶的子文件夹,例如:S3://myS3Bucket/345_2018_03_05。使用Kinesis Firehose或AWS Lambda是否有可能实现此目的?
目前我能想到的唯一方法是为每个可能的ID创建一个Kinesis流,并将它们指向同一个桶,然后在应用程序中发送我的事件到这些流中,但我希望避免这种情况,因为有很多可能的ID。