我需要每秒处理100条记录。这些记录是简单的JSON体,应该收集它们,然后处理/转换成数据库。你知道吗
有几个问题。。。你知道吗
1)动觉学是否适用于此?还是SQS更适合?你知道吗
2)在使用kinesis时,我是想使用这里所示的python示例:https://aws.amazon.com/blogs/big-data/snakes-in-the-stream-feeding-and-eating-amazon-kinesis-streams-with-python/还是应该用KCL实现生产者和消费者?有什么区别?你知道吗
3)Kinesis是否为消费者的管理提供了任何帮助,还是我只是在EC2实例上运行它们并自己管理它们?你知道吗
4)访问数据的正确模式是什么?我不能错过任何记录,因此我假设我将从“TRIMïu HORIZON”而不是“LATEST”获取记录。如果是,如何管理副本?换句话说,我的消费者如何从流中获取记录,如何处理掉的消费者,等等,并且总是知道他们正在获取所有记录?你知道吗
谢谢!你知道吗
TRIM_HORIZON
。如果您的数据中存在重复项,您的消费者应该通过自己记账来处理这些重复项。至于消费者下跌等,KCL处理这些案件优雅。你知道吗相关问题 更多 >
编程相关推荐