我正面临着一个我不相信是新奇的问题,但无论如何,我都很难找到一个与我们的系统相适应的解决方案。我们有一个源源不断的事件流进入AWS运动。按我的理解,Kinesis的工作方式是根据新事件对某些查询进行响应和重新计算。现在我要做的是对缺乏事件做出反应。示例:我想检测某个事件(比如登录事件)在连续x天内没有发生。
现在,我的问题不一定是关于Kinesis的(但肯定可以考虑如何在那里完成这一任务),而是关于在某个流处理器中“清除”事件的概念/将事件的缺位视为事件。我正在寻找关于其他平台如何处理这个问题的材料,嗯,在规模上处理这个问题。我能想到的一个很大的用例是检测某个日志流何时失败或停止生成日志,这可能表明一个问题。
发布于 2020-03-26 08:53:22
典型的实现是一个计时器,它检查某个事件是否以周期性间隔发生,如果没有,则执行一些操作。有时被称为看门狗定时器。
https://softwareengineering.stackexchange.com/questions/406972
复制相似问题