Prometheus를 활용한 LF Edge eKuiper 규칙 상태 모니터링
LF Edge eKuiper는 끊임없이 유입되는 데이터 스트림을 처리하는 규칙(Rule) 기반의 스트리밍 엔진입니다. 각 규칙은 독립적인 작업 단위로 실행되며, 운영 환경에서는 이러한 규칙들이 정상적으로 동작하고 있는지, 데이터 처리 지연이나 오류가 발생하지 않는지 실시간으로 감시하는 것이 매우 중요합니다. 이를 위해 eKuiper는 CNCF의 대표적인 모니터링 도구인 Prometh ...
7월 30일 04:17에 게시됨
Flink SQL 기반 데이터 처리 설정 및 사용법
Flink SQL 환경 구성
Flink의 Table API와 SQL 기능은 flink-table 모듈을 통해 제공되며, 프로젝트에 다음 의존성을 추가해야 합니다:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table_2.11</artifactId>
<version>1.5.0</version>
</dependency>
또한 스칼라 기반의 배치 또는 스트 ...
6월 23일 22:33에 게시됨