我正在权衡使用flink或storm and ignite的物联网用例设计方法的利弊。假设我创建了一个规则流，说明如果任何车辆超过了规则中设置的阈值速度限制，那么该流应该触发一个操作，向驾驶员发送sms号码。我创建的流在mongodb中保存为json。我在db的另一个表中列出了1000个obd设备（一秒钟内连续发送3次数据）和相关的驱动程序移动号码。在我的设计中，我也在考虑使用内存数据库。Kafka正在处理数据收集。
使用数据（obd设备的唯一id和驾驶员移动号码）更新流程的最快和最具可扩展性的实现方法是什么？我有在数据库和流数据从每个车载诊断设备（当前车速）。