flow-manager

フローマネージャー

目的

フロー（カスタマージャーニー／キャンペーン）を管理します。フローの作成、更新、削除に加え、遅延、エクスポート、条件分岐、A/B テスト、アフィニティルーティングなどのステップを管理します。

環境

認証済みの API アクセスが必要です。認証情報の解決については、../references/auth.md を参照してください。

API エンドポイント

フローの一覧表示

curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui" \
  -H "Authorization: ${LYTICS_API_TOKEN}"

フローの取得

curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui/${FLOW_ID}" \
  -H "Authorization: ${LYTICS_API_TOKEN}"

フローバージョンの取得

curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui/${FLOW_ID}/${VERSION}" \
  -H "Authorization: ${LYTICS_API_TOKEN}"

フローの作成

curl -s -X POST "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui" \
  -H "Authorization: ${LYTICS_API_TOKEN}" \
  -H "Content-Type: application/json" \
  -d '{ ... flow payload ... }'

フローの更新

curl -s -X POST "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui/${FLOW_ID}" \
  -H "Authorization: ${LYTICS_API_TOKEN}" \
  -H "Content-Type: application/json" \
  -d '{ ... updated flow payload ... }'

フローの削除

curl -s -X DELETE "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui/${FLOW_ID}" \
  -H "Authorization: ${LYTICS_API_TOKEN}"

フローステップ用ワークの作成

curl -s -X POST "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/ui/${FLOW_ID}/step/${STEP_ID}/work" \
  -H "Authorization: ${LYTICS_API_TOKEN}" \
  -H "Content-Type: application/json" \
  -d '{ ... work config ... }'

フロー状態の一覧表示

curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/flow/state" \
  -H "Authorization: ${LYTICS_API_TOKEN}"

フローペイロード

{
  "id": "flow_name",
  "label": "Display Name",
  "description": "What this flow does",
  "entry_segment_id": "segment_id",
  "entry_condition": "on_segment_entry",
  "reentry_allowed": false,
  "reentry_delay": "24h",
  "state": "draft",
  "steps": [
    {
      "id": 1,
      "label": "Step 1",
      "type_hint": "work_export",
      "slug": "step_1",
      "next": 2,
      "work_id": "work_id",
      "work_config": {}
    },
    {
      "id": 2,
      "label": "Wait 24 hours",
      "type_hint": "delay",
      "slug": "delay_step",
      "next": 3,
      "delay": "24h"
    }
  ]
}

フローの状態

状態	説明
draft	編集可能で、処理は行われません
running	ユーザーを処理中です
draining	残りのユーザーを処理しながら、正常に停止しています
deleted	論理削除されています

エントリー条件

条件	説明
in_segment	現在セグメント内にいるユーザーを対象にトリガーされます
on_segment_entry	ユーザーがセグメントに入ったときのみトリガーされます

ステップの種類

種類	説明	主なフィールド
work_export	外部システムにエクスポートします	work_id, work_config
delay	次のステップまで待機します	delay（期間を表す文字列）
conditional	FilterQL 条件で分岐します	split_conditions
affinity	コンテンツアフィニティに基づいてルーティングします	split_affinities, affinity_config_id
ab_testing	確率に基づいてランダムに分岐します	split_probabilities
work_export_exit	フロー終了時にエクスポートします	work_id, work_config

動作

読み取り操作の場合

すぐに実行し、フローの構造を視覚的なステップチェーンとして表示します。

書き込み操作の場合

確認ゲートパターンを使用します。状態を変更する場合（draft -> running、running -> draining）は、その影響を明示的に警告してください。

エラー処理

• 無効なエントリーセグメント：まずセグメントが存在することを確認してください
• 無効なステップ参照：next ID が既存のステップを指していることを確認してください
• 状態遷移エラー：有効な遷移は draft->running と running->draining のみです

依存関係

• 使用：../references/auth.md、../references/api-client.md、../references/confirmation-gate.md
• 関連：segment-manager skill（エントリーセグメント用）、job-manager skill（ワークステップ用）