16. Flow サービス

client.flow() でアクセスします。PlantPulse のビジュアルワークフロー（Flow）と、その中のノード（Flow Node）を照会します。V5 で新たに追加されたサービスです。

参考: V5 の Flow サービスは 読み取り専用です。Flow の作成／変更／実行は UI または Flow エンジン専用 API で行ってください。Flow エンジンの詳細な動作原理はフローエンジンのドキュメントを参照してください。

16.1 メソッド一覧

メソッド	戻り値の型	HTTP	エンドポイント
get(flow_id)	FlowResponseV5 または null	GET	/api/v5/flow/{id}
list()	List<FlowResponseV5>（統計を含む）	GET	/api/v5/flow
listNodes(flow_id)	List<FlowNodeResponseV5>	GET	/api/v5/flow/{id}/node

16.2 FlowResponseV5 DTO

フィールド	型	説明
flow_id	String	Flow ID (PK)
flow_name	String	Flow 名
description	String	説明
enabled	boolean	有効化の有無
is_root	boolean	ルート Flow かどうか
debug_mode	boolean	デバッグモード
insert_user / insert_date	String	登録者／時刻
update_user / update_date	String	変更者／時刻
node_count	int	ノード数（統計）
trigger_count	int	トリガー数（統計）
error_count	long	累積エラー数（統計）

16.3 FlowNodeResponseV5 DTO

フィールド	型	説明
flow_node_id	String	ノード ID (PK)
flow_id	String	所属 Flow
type	String	ノードタイプ（trigger、function、action など）
name	String	ノード名
configuration_json	String	ノード設定 JSON 文字列
position_x / position_y	int	キャンバス上の位置
debug_mode	boolean	ノード単位のデバッグ

16.4 使用例

Flow 一覧（統計を含む）

import java.util.List;
import plantpulse.api.v5.dto.response.FlowResponseV5;

List<FlowResponseV5> flows = client.flow().list();
for (FlowResponseV5 f : flows) {
    System.out.printf("[%s] %s — 노드 %d개, 트리거 %d개, 에러 %d건%n",
        f.isEnabled() ? "ON" : "OFF",
        f.getFlow_name(),
        f.getNode_count(),
        f.getTrigger_count(),
        f.getError_count());
}

出力例:

[ON]  생산 카운트 집계 — 노드 8개, 트리거 1개, 에러 0건
[ON]  알람 알림 라우팅 — 노드 12개, 트리거 3개, 에러 2건
[OFF] (실험) ML 예측 — 노드 5개, 트리거 0개, 에러 0건

Flow の単件照会

FlowResponseV5 flow = client.flow().get("flow_001");
if (flow != null && !flow.isEnabled()) {
    System.err.println("Flow가 비활성 상태: " + flow.getFlow_name());
}

Flow のノード一覧

import plantpulse.api.v5.dto.response.FlowNodeResponseV5;

String flowId = "flow_001";
List<FlowNodeResponseV5> nodes = client.flow().listNodes(flowId);
for (FlowNodeResponseV5 n : nodes) {
    System.out.printf("  [%s] %s (%s)%n",
        n.getType(), n.getName(), n.getFlow_node_id());
}

エラーが発生した Flow の特定

import java.util.stream.Collectors;

List<FlowResponseV5> errored = client.flow().list().stream()
        .filter(f -> f.getError_count() > 0)
        .collect(Collectors.toList());

System.out.println("에러 발생 Flow: " + errored.size() + "개");
for (FlowResponseV5 f : errored) {
    System.out.printf("  %s: %d건%n", f.getFlow_name(), f.getError_count());
}

16.5 活用シナリオ

シナリオ — Flow ヘルスダッシュボード

while (running) {
    List<FlowResponseV5> all = client.flow().list();

    long total    = all.size();
    long enabled  = all.stream().filter(FlowResponseV5::isEnabled).count();
    long errored  = all.stream().filter(f -> f.getError_count() > 0).count();
    long triggers = all.stream().mapToInt(FlowResponseV5::getTrigger_count).sum();

    updateUI(total, enabled, errored, triggers);
    Thread.sleep(5_000);
}

次のステップ

• フローエンジンガイド — Flow の動作原理（別ドキュメント）
• 統合例 — Flow と API の連携例