クイックスタート：Anthropicノードを使ったFlowの作成

このページでは、Claude 3 Sonnetを使用してフォールト分類を行い、受信したテレメトリに基づいて是正推奨を生成する方法を示します。これは、スマートファクトリーやビルディングなどのIoTシステムがデバイスからのステータスメッセージを受信し、それらの問題を自動かつインテリジェントに解釈する実際のシナリオをシミュレートしています。

シナリオの説明

多くの産業やスマートビルディングのシナリオでは、IoTデバイスが単一のMQTTメッセージ内で複数のメトリクスを報告します。例えば、電力監視デバイスは複数の回路にわたる電力消費を1つのペイロードで送信する場合があります。

各メッセージはトピック devices/power_report にパブリッシュされ、以下を含みます：

• device_id：デバイスの識別子
• circuit_1、circuit_2、circuit_3 などの複数の数値メトリクス
• status や timestamp などの数値以外のフィールド

このシナリオの目的は、LLM（Claude 3 Sonnet）を使用してメッセージ内のすべての数値の合計（すなわち回路全体の総電力消費量）を計算し、その数値結果のみを下流処理や課金のために再パブリッシュすることです。

サンプルメッセージ

{
  "device_id": "pmu-1008",
  "circuit_1": 120.5,
  "circuit_2": 98.7,
  "circuit_3": 103.2,
  "status": "nominal",
  "timestamp": "2025-06-06T10:00:00Z"
}

期待される出力（Claudeから）

322.4

この値は、すべての数値回路読み取り値の合計です。

Flowの作成

前提条件

有効な Anthropic APIキー を用意し、正しいAPIバージョン（例：2023-06-01）を設定してください。

1. Flowデザイナーページで New Flow ボタンをクリックします。

2. Messages ノードを追加します。

   • ソースパネルから Messages ノードをドラッグします。
   • トピックを devices/power_report に設定します。
   • 保存 をクリックします。

3. Anthropic ノードを追加します。

   • 処理セクションから Anthropic ノードをドラッグし、データ処理ノードに接続します。

   • ノードを設定します：

     • Input：payload を入力します。

     • System Message：以下のような動的プロンプトを入力できます：

       あなたは電力消費計算機です。さまざまなキーを持つ入力JSONオブジェクトが与えられた場合、すべての数値（例：回路の読み取り値）を合計し、合計値のみを返してください。

     • Base URL：デフォルトは https://api.anthropic.com/v1 ですが、Anthropic API形式に対応した任意のBase URLを使用できます。

       注意

       公開アドレスのBase URLを使用する場合は、NATゲートウェイが有効になっていることを確認してください。プライベートネットワーク上でAnthropic API形式に対応したモデルのBase URLを使用する場合は、VPCピアリングまたはPrivateLinkのいずれかを設定してください。

     • Model：claude-3-sonnet-20240620 を選択します。

     • Max Tokens：50 を入力します。

     • Anthropic Version：2023-06-01 を入力します。

     • API Key：Anthropic APIキーを入力します。

     • Output Result Alias：total_power を入力します。

   • 保存 をクリックします。

4. Republish ノードを追加します。

   • シンクセクションから Republish ノードをドラッグし、Anthropicノードに接続します。
   • トピックを devices/power_total に設定します。
   • ペイロードを ${total_power} に設定します。
   • 保存 をクリックします。

5. すべてのノードを接続し、右上の 保存 をクリックしてFlowを保存します。

   

6. Flowとフォームルールは相互運用可能です。ルール設定ページでSQLや関連ルール設定も確認できます。

   

Flowのテスト

1. MQTTクライアントをEMQX Cloudに接続します。

   Flowを素早くテストするには、デプロイメントメニューの オンラインテスト を使ってMQTTクライアントをシミュレートできます。あるいは、MQTTXツールや実際のMQTTクライアントも利用可能です：

   • デプロイメントに接続します。
   • トピック devices/power_total をサブスクライブします。

2. テストを開始します。

   • Flowデザイナーで任意のノードをクリックし、編集パネルを開きます。

   • Edit Flow をクリックし、続けて Start Test をクリックすると、画面下部にテストパネルが開きます。

   • Input Simulated Data をクリックし、以下のメッセージをトピック devices/power_report にパブリッシュするために Submit Test をクリックします：

     {
       "device_id": "pmu-1008",
       "circuit_1": 120.5,
       "circuit_2": 98.7,
       "circuit_3": 103.2,
       "status": "nominal",
       "timestamp": "2025-06-06T10:00:00Z"
     }

3. 結果とノードの処理メトリクスを確認します。

   • Flowの正常な実行結果を確認できます。

     

   • オンラインテスト ページに戻ると、AIが生成した要約（例：

     322.4

     ）を受信できます。

   • テスト結果が失敗した場合は、エラーメッセージが表示されます。

   • Anthropic ノードの実行統計やメトリクスを確認するには、Flowデザイナーでノードをクリックし編集パネルを開き、Metrics タブをクリックしてください。