plantpulse-cep (Complex Event Processing)
Rolle
Complex Event Processing Engine. Erkennt zeitliche und logische Muster mehrerer Sensor-Events in Echtzeit und führt Alarme, Flow-Auslöser und Automatisierungen aus.
| Element | Wert |
|---|---|
| Modulname | plantpulse-cep |
| Installationspfad | /opt/kopens/plantpulse-platform/plantpulse-cep/ |
| Port | 7400 (HTTP) · 7401 (TLS) |
| Engine | Esper CEP (Web-App auf eingebautem Tomcat) |
pd Dienst | cep — nur MASTER |
| API-Authentifizierung | X-API-Key: <PP_CEP_API_KEY> |
| Konsolenlogin | PP_CEP_WEB_USER / PP_CEP_WEB_PASSWORD — wenn leer, nur Konsole geschlossen |
Anwendungsbeispiel
"Wenn die Temperatur 5 Sekunden lang 80°C übersteigt UND der Druck gleichzeitig um mindestens 15% über dem Durchschnitt liegt, dann Gefahrenalarm auslösen"
Solche komplexen Bedingungen werden in EQL (Event Query Language) definiert; die CEP-Engine gleicht sie in Echtzeit ab und veröffentlicht die Ergebnisse.
Architektur
Verzeichnisstruktur
plantpulse-cep/
├── config/plantpulse-cep.properties # 생성물 ← /etc/kopens/conf/plantpulse-cep.properties.template
├── bin/start.sh stop.sh
├── logs/
└── server/ # 내장 Tomcat — webapps/ROOT.war · logs/catalina.<date>.log
Hauptkonfiguration
Wichtigste Elemente der Vorlage /etc/kopens/conf/plantpulse-cep.properties.template. Platzhalter werden beim Rendering gefüllt.
# 캐시 · HA 스냅샷 (Valkey)
cache.host=${PP_REDIS_HOST}
cache.port=${PP_REDIS_PORT}
cache.password=${PP_REDIS_PASSWORD}
cep.ha.enabled = true # 재시작 때 엔진 상태(윈도 · 테이블) 보존
cep.ha.snapshot.interval_ms = 1000
# 이벤트 저장 (Cassandra)
storage.host=${PP_CASSANDRA_HOST}
storage.port=${PP_CASSANDRA_PORT:9042}
storage.keyspace=${PP_KEYSPACE}
cep.storage.ttl_seconds=864000 # 10일
# 처리 스레드
cep.consumer.thread_count=16
cep.stream.shard_count=16
cep.async.max_pool_size=256
# 인증
cep.api.key=${PP_CEP_API_KEY} # 관리 API 의 X-API-Key
cep.web.user=${PP_CEP_WEB_USER} # 콘솔 로그인
cep.web.password=${PP_CEP_WEB_PASSWORD}
Werte ändern Sie nach Konfiguration ändern — Vorlagen, API-Schlüsselrotation nach Passwörter und API-Schlüssel ändern.
Authentifizierung
Die Management-API authentifiziert sich über den Header X-API-Key. Der Wert muss mit PP_CEP_API_KEY der Server-Konsole identisch sein; wenn nur einer geändert wird, folgt sofort 401 — passwd.sh PP_CEP_API_KEY ändert beide zusammen.
curl -H "X-API-Key: ${PP_CEP_API_KEY}" http://127.0.0.1:7400/api/v1/status
EQL-Beispiele
Registrieren und stellen Sie EQL im Menü AUTOMATION > CEP der Server-Konsole oder in der CEP-Konsole https://<server-ip>:7401/ bereit.
-- 5초 윈도에서 평균 온도가 80도 초과
@Name('high-temp')
SELECT tagId, avg(value) AS avg_temp
FROM TagPoint(tagId = 'TEMP_REACTOR_01').win:time(5 sec)
GROUP BY tagId
HAVING avg(value) > 80
OUTPUT EVERY 1 sec;
-- 두 태그의 시간 정렬 패턴
@Name('temp-pressure-correlation')
SELECT a.tagId AS temp_id, b.tagId AS pressure_id
FROM pattern [
every a = TagPoint(tagId = 'TEMP_01' AND value > 80)
-> b = TagPoint(tagId = 'PRESS_01' AND value > 100) WHERE timer:within(10 sec)
];
Syntax finden Sie unter EQL-Referenz.
Operationsbefehle
docker exec plantpulse-datalake pd status cep
docker exec plantpulse-datalake pd restart cep
docker exec plantpulse-datalake pd logs --lines 100 cep
# 표준 헬스체크 (익명, readiness — 엔진 + 컨슈머 + 복구 완료 · Valkey 연결 시에만 UP)
curl -fsS http://127.0.0.1:7400/api/health
# 200 {"status":"UP","service":"plantpulse-cep-server-web",…,"checks":{"engine":true,"redis":true}}
# 503 {"status":"STARTING"} 기동 중 / 503 {"status":"DEGRADED"} 의존성 다운
Häufig auftretende Probleme
| Symptom | Ursache | Abhilfe |
|---|---|---|
| Regel funktioniert nicht | Nicht bereitgestellt | Bereitstellung in Konsole durchführen |
| Verarbeitungsverzögerung | Fenster-Speicher unzureichend | EQL-Fenster verkleinern oder Heap erhöhen |
| Kafka-Lag steigt | Verarbeitungs-Threads unzureichend | cep.consumer.thread_count erhöhen (Vorlage) |
| API 401 | API-Schlüssel stimmen nicht überein | passwd.sh PP_CEP_API_KEY |
| Konsolenlogin abgelehnt | PP_CEP_WEB_PASSWORD leer | Webanwendungs-Anmeldekonto |