我正在权衡使用Flink或Storm and Ignite的物联网用例设计方法的优缺点。假设我创建了一个规则流，说明如果任何车辆超过了规则中设置的阈值速度限制，那么该流应该触发向驾驶员号码发送短信的操作。我创建的流在MongoDB中保存为JSON。我在DB的另一个表中有一个1000个OBD设备的列表(它在一秒钟内连续发送3次数据(和相关的驾驶员手机号码。在我的设计中，我也在考虑使用内存数据库。数据收集是用Kafka处理的。
用数据(OBD设备的唯一ID和驾驶员手机号码(更新流程的最快、最可扩展的实施方法是什么？我有来自每个OBD设备的数据库和流数据(车辆的当前速度(。
如果您将Ignite配置为基于磁盘的数据库之上的缓存，那么您可以使用Ignite缓存存储和写入和读取功能，将所有更新自动传播到内存缓存和数据库：https://apacheignite.readme.io/docs/3rd-party-store