plantpulse-batch (バッチ処理)

役割

スケジュール基盤のバッチ作業実行エンジン。日/時間/月単位の統計集計、データクリーンアップ、レポート生成、OEE/RAM/EMS プラグイン計算を実行します。

項目	値
モジュール名	plantpulse-batch
インストール路径	/opt/kopens/plantpulse-platform/plantpulse-batch/
ポート	9500
スケジューラ	Quartz (PostgreSQL JDBC store)

主な責務

• 時間別 / 日別 / 月別集計 (タグ → アセット)
• OEE / RAM / EMS プラグイン計算
• レポート自動生成
• データ保存期間ポリシー適用
• データ整合性検証

構成

ディレクトリ構造

plantpulse-batch/
├── config/
│   └── plantpulse-batch.properties    # 배치 설정 (외부화 — 배포해도 유지)
├── bin/start.sh stop.sh log-viewer.sh
├── logs/system.log
└── server/                             # 내장 Tomcat (webapps/ROOT.war)
    └── conf/server.xml

主要設定

plantpulse-batch/config/plantpulse-batch.properties — configure.sh が env.sh 値を置換して生成されます。Web アプリケーション内部ファイルは編集しないでください (デプロイ時に消去されます)。

# 메타스토어 (PostgreSQL)
metastore.url=jdbc:postgresql://${PP_POSTGRES_HOST}:${PP_POSTGRES_PORT}/${PP_DB_NAME}
metastore.user=${PP_PG_USER}
metastore.password=${PP_PG_PASSWORD}

# 시계열 저장소 (Cassandra) / TSE
storage.db.host=${PP_CASSANDRA_HOST}
storage.db.keyspace=${PP_KEYSPACE}
tse.host=${PP_TSE_HOST}

# 배치 동작
batch.timer_schedule_delay=5000              # 배치 타이머 주기 (ms)
batch.thread_pool_batch_thread_size=4        # 배치 워커 스레드 수
batch.buffer_drain_limit_size=10000          # 1회 드레인 최대 건수
batch.sync.tse.enabled=true                  # TSE 동기화
batch.sync.external.db.enabled=false         # 외부 DB 동기화 (TimescaleDB/InfluxDB/QuestDB)

運用コマンド

cd /opt/kopens/plantpulse-platform/plantpulse-datalake-cli/bin

./restart-batch.sh
./pd status                # 9500 RUNNING 확인

# 표준 헬스체크 (익명, readiness — 배치 파이프라인 가동·Redis 연결 시에만 UP)
curl -fsS http://127.0.0.1:9500/api/health
# 준비 완료: 200 {"status":"UP","service":"plantpulse-batch-web","ts":...,"checks":{"timer":true,"redis":true}}
# 기동 전:   503 {"status":"STARTING",...} / 기동 후 의존성 다운: 503 {"status":"DEGRADED",...}

コンソールの システム > バッチ管理 メニューから、個別ジョブの実行 / 一時停止 / トリガが可能です。

よくある問題

症状	原因	対処
ジョブが実行されない	Quartz ロック / クラスタ競合	qrtz_locks テーブルを確認
集計結果の欠落	対象データの時間範囲エラー	バッチ周期(batch.timer_schedule_delay) と対象期間の設定を確認
メモリ不足	大規模ウィンドウ処理	ヒープサイズ増加またはウィンドウ分割

関連ドキュメント

• モジュール インデックス
• プラグイン (OEE/RAM/EMS) ユーザガイド
• 開発者: スケジューラアーキテクチャ