我们每天都会收到大量的日志文件。我正在开发一个应用程序，它使用kafka将数据提供给apachespark进行实时处理。实际的想法是处理spark中的日志文件并识别模式。我可以收集Spark处理的见解。
现在我想建立一个通知机制。因此，当spark处理传入的日志时，如果发现关键事件，它应该发送警报。我希望该警报作为推送通知传递。我怎样才能做到这一点？
附言：我可以发邮件提醒。我已经准备好了，但推送通知可能是件大事。所以帮帮我！
我们每天都会收到大量的日志文件。我正在开发一个应用程序，它使用kafka将数据提供给apachespark进行实时处理。实际的想法是处理spark中的日志文件并识别模式。我可以收集Spark处理的见解。
现在我想建立一个通知机制。因此，当spark处理传入的日志时，如果发现关键事件，它应该发送警报。我希望该警报作为推送通知传递。我怎样才能做到这一点？
附言：我可以发邮件提醒。我已经准备好了，但推送通知可能是件大事。所以帮帮我！
1条答案
按热度按时间bqucvtff1#
您可能需要 checkout 一个应用程序。这个应用程序读取（推或拉）或写入kafka，所有处理都可以在内存集群结构中（内部引擎）完成，具有非常高的频率容量（其中一种情况是一天内实时处理25亿行日志文件）。它创建邮件、sms、rdbms、DML、网站弹出窗口等作为输出操作。这是一个名为evam的应用程序的链接。