Как создать оповещение об отключении питания с помощью потоковой передачи

Question

Как создать оповещение об отключении питания с помощью потоковой передачи flink.

Например: у меня есть сайт, который отправляет данные на flink-job через kafka.

Допустим, мы получили данные о 26 апреля 1992 10:23:52 после того, как у этого сайта возникла проблема, он не отправлял никаких данных. В этом случае мы хотим сгенерировать предупреждение о POWER_OFF.

Возможно ли использовать flink?

Answer 1

Этот тип обнаружения сердцебиения легко достигается с помощью ProcessFunction. В документации есть пример .

Вы также можете сделать это с CEP: { ссылка }