我有一个用例,在这个用例中,我需要对发送到我的Kinesis Firehose流的有效负载进行API调用,然后将其存储到S3中。
流程如下: Kinesis数据流-> Kinesis Firehose ->转换Lambda ->调用以获取与当前记录相关的附加数据-> Kinesis Firehose -> S3。
基本上,对于由我的Kinesis Firehose流使用的记录,我需要调用另一个后端服务来获取与该记录相关的附加数据,然后再将其存储到S3中,以便我们的电子病历作业使用和写入查询。
我的问题是,是否可以从Kinesis Firehose转换Lambda进行网络调用。我认为它应该是,因为它只是另一个Lambda函数。我还想知道在Kinesis Firehose转换Lambda中进行API调用是否违反最佳实践。
任何洞察力都是值得感谢的!
发布于 2021-04-15 08:06:26
我不认为在转换lambda函数中进行网络调用有任何问题。您唯一需要确保的是,在转换为firehose接受格式后,将所有recordIds返回到firehose,如aws doc中所示
https://stackoverflow.com/questions/67064136
复制相似问题