クイックスタート：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）を設定してください。
FlowsページでCreate Flowボタンをクリックします。
Messagesノードを追加します。
- ソースパネルからMessagesノードをドラッグします。
- トピックを
devices/power_reportに設定します。 - Saveをクリックします。
Anthropicノードを追加します。
- 処理セクションからAnthropicノードをドラッグし、データ処理ノードに接続します。
- ノードを設定します：
Input：
payloadを入力します。System Message：以下のような動的プロンプトを入力できます。
あなたは電力消費計算機です。様々なキーを持つJSONオブジェクトが入力された場合、すべての数値（例：回路の読み取り値）を合計し、合計値のみを返してください。Model：
claude-3-sonnet-20240620を選択します。Max Tokens：
50を入力します。Anthropic Version：
2023-06-01を入力します。API Key：AnthropicのAPIキーを入力します。
Base URL：空欄のままにします。
Output Result Alias：
total_powerを入力します。
- Saveをクリックします。
Republishノードを追加します。
- シンクセクションからRepublishノードをドラッグし、Anthropicノードに接続します。
- トピックを
devices/power_totalに設定します。 - ペイロードを
${total_power}に設定します。 - Saveをクリックします。
右上のSaveをクリックしてFlowを保存します。
Flowとフォームルールは相互運用可能です。SQLや関連するルール設定はRuleページでも確認できます。
Flowのテスト
MQTTクライアントをEMQXに接続します。
Flowを素早くテストするには、ダッシュボードのDiagnostic Tools -> WebSocket Clientを使ってMQTTクライアントをシミュレートできます。あるいは、MQTTXツールや実際のMQTTクライアントも利用可能です：
- EMQXサーバーに接続します。
- トピック
devices/power_totalをサブスクライブします。
テストを開始します。
Flowデザイナーで任意のノードをクリックし、編集パネルを開きます。
Editをクリックし、続けてStart Testをクリックして画面下部にテストパネルを開きます。
Input Simulated Dataをクリックし、以下のメッセージをトピック
devices/power_reportにパブリッシュするためSubmit Testをクリックします：json{ "device_id": "pmu-1008", "circuit_1": 120.5, "circuit_2": 98.7, "circuit_3": 103.2, "status": "nominal", "timestamp": "2025-06-06T10:00:00Z" }
結果とノードの処理メトリクスを確認します。
Flowの正常な実行結果を確認できます。
WebSocket Clientページに戻ると、AI生成の集計結果を受信できます：
322.4
テストが失敗した場合は、エラーメッセージが表示されます。
Anthropicノードの稼働状況や統計情報を確認するには、編集ページを閉じてノードをクリックし、編集パネルのOverviewタブを開きます。
