arch-distributed

arch-distributed

目的

このスキルを使うと、OpenClaw で CAP 定理、Raft や Paxos などのコンセンサスアルゴリズム、結果整合性、分散トランザクション（2PC と SAGA）、CRDT など、分散システムの概念を分析、設計、実装できます。コードスニペットの生成、トレードオフの評価、分散アーキテクチャにおける動作のシミュレーションに利用できます。

使用する場面

マイクロサービス、クラウドデータベース、ブロックチェーンシステムなど、ネットワーク分断に直面するスケーラブルなアプリケーションの構築時に、このスキルを使用してください。CAP 定理に基づく判断（可用性を一貫性より優先するなど）、耐障害性のあるクラスターでのコンセンサス、データレプリケーションにおける結果整合性の処理に利用できます。単一サーバーアプリのような、分散処理を伴わないタスクには使用しないでください。

主な機能

• CAP 定理の分析：事前定義されたチェックを使って、一貫性、可用性、分断耐性の観点からシステム設計を評価します。
• コンセンサスの実装：リーダー選出やログレプリケーションを含む、Raft または Paxos のロジックを生成します。
• 結果整合性の処理：アンチエントロピーや読み取り修復などの解決メカニズムをシミュレーションします。
• トランザクションの管理：アトミックコミットには 2PC を、補償アクションを伴う長時間実行プロセスには SAGA を生成します。
• CRDT の活用：競合なくマージできるカウンターやセットの実装を作成します。

使用パターン

スキル ID とパラメーターを指定して、OpenClaw の CLI または API からこのスキルを呼び出します。CLI では、openclaw run arch-distributed --input <JSON_FILE> を実行して設定ファイルを処理します。コードでは、OpenClaw の SDK をインポートし、openclaw.skills.execute('arch-distributed', params={}) を呼び出します。"topic"（例："cap"）や "action"（例："analyze"）などのキーを含む JSON 入力を必ず指定してください。たとえば、CAP のトレードオフを確認する場合は、次のように入力を構成します：{"topic": "cap", "system": {"consistency": "strong", "availability": "high"}}。出力をパイプで渡してスキルを連鎖させることもできます。たとえば、データベース設計スキルの後にこのスキルを実行します。

一般的なコマンド／API

簡単なタスクには OpenClaw の CLI を使用します：openclaw run arch-distributed --topic consensus --algorithm raft --output json（フラグ：--topic は CAP／Raft、--algorithm は Paxos／Raft、--output は形式を指定します）。API の場合は、次の本文を指定して /api/v1/skills/arch-distributed に POST を送信します：{"apiKey": "$OPENCLAW_API_KEY", "params": {"action": "implement", "type": "2pc"}}。SDK 統合用のコードスニペット：

import openclaw
response = openclaw.execute_skill('arch-distributed', {'topic': 'crdts', 'type': 'counter'})
print(response['code'])  # Outputs CRDT implementation code

設定形式：複数ノードのシミュレーションには、{"consensus": {"algorithm": "raft", "nodes": 5}} のような JSON ファイルを使用します。認証は環境変数で設定します：export OPENCLAW_API_KEY=$SERVICE_API_KEY。

統合に関する注意

アプリのワークフロー内で OpenClaw の出力をラップするなどして統合します。たとえば、CI/CD パイプラインからこのスキルを呼び出して、分散システムの設計を検証できます。外部ツールと連携する場合は、Kubernetes などのシステムに出力を渡します（たとえば、Raft ベースのステートフルセット用 YAML を生成します）。データベースと併用する場合は、{"db": "cassandra", "consistency": "eventual"} のように params でドライバーを指定して、互換性を確保してください。依存関係を処理するには、pip install openclaw で OpenClaw SDK をインストールし、認証リクエスト用に $OPENCLAW_API_KEY を設定します。本番環境での問題を避けるため、サンドボックス環境で統合をテストしてください。

エラー処理

よくあるエラーには、無効なパラメーター（サポートされていないアルゴリズムなど）、シミュレーション中のネットワーク障害、認証の問題があります。応答コードを確認してください。入力が不正な場合は HTTP 400、$OPENCLAW_API_KEY がない場合は 401 です。コードでは、呼び出しを try-except ブロックで囲みます：

try:
    result = openclaw.execute_skill('arch-distributed', {'topic': 'cap'})
except openclaw.SkillError as e:
    if e.code == 'INVALID_TOPIC':
        print("Use a valid topic like 'consensus'")  # Handle specifically

CLI では、openclaw run arch-distributed --debug を使ってエラーを解析し、詳細なログを取得します。一時的なエラー（コンセンサスの失敗など）は、指数バックオフを使って最大 3 回再試行します。

使用例

1. CAP 定理を使ってシステムを設計するには、openclaw run arch-distributed --topic cap --system '{"consistency": "weak", "availability": "high"}' を実行すると、次のような JSON の分析結果が得られます：{"recommendation": "Prioritize availability; use eventual consistency for reads."}。これを使って、シンプルなキー値ストアのコードを生成します。
2. Raft コンセンサスを実装するには、API 経由で POST /api/v1/skills/arch-distributed with {"params": {"action": "implement", "algorithm": "raft"}} を実行すると、次のようなスニペットが返されます：

type RaftNode struct {
    ID int
    State string  // "follower", "candidate", "leader"
}

これを Go アプリケーションに統合して、分散ログを作成します。

グラフの関係

• cluster：se-architecture に関連しています（例：arch-microservices などのスキルとタグを共有しています）。
• タグを介して接続されています："distributed" は data-processing などのスキルに、"consensus" は security-auth に、"cap" は database-design に、"architecture" は deployment-tools にリンクしています。