EMQX Cloud

日本語

简体中文
English

日本語

简体中文
English

Appearance

お問い合わせ
お問い合わせ

最初のエージェントのビルドとデプロイ ​

このガイドでは、EMQX Agents を使用して完全なイベント駆動型エージェントを作成する手順を説明します。工場のデバイスからの MQTT メッセージを監視し、各読み取り値をローリング平均と比較して、デバイスの平均温度が閾値を超えた場合にアラートをパブリッシュする温度異常モニターを構築します。

このガイドの最後には、以下を実現しています。

  • EMQX Broker に接続された稼働中の EMQX Agents デプロイメント
  • ブローカー用に構成されたコネクター
  • ライブ MQTT イベントに反応するデプロイ済みエージェント

前提条件 ​

  • 有効なプロジェクトを持つ EMQX Cloud アカウント
  • Running 状態の EMQX Broker デプロイメント
  • テストメッセージをパブリッシュするための MQTT クライアント（例：MQTTX）

ステップ 1: EMQX Agents デプロイメントの作成 ​

EMQX Agents はすべてのユーザーに Public Beta として提供されています。EMQX Cloud コンソールから直接 Agents デプロイメントを作成できます。

  1. EMQX Cloud コンソールにログインし、プロジェクトを開きます。

  2. EMQX Agents カードで + New をクリックします。

    プロジェクトページから EMQX Agents デプロイメントを作成

  3. Agents デプロイメントのリージョンを選択します。Google Cloud のみがサポートされているクラウドプロバイダーです。

  4. [任意] このガイドで Broker とプライベート接続を使用する場合は、Network Association (Optional) で Broker ネットワークを選択します。ネットワークの関連付けは、コネクターが使用する Broker アドレスを変更しません。

  5. Deploy をクリックし、操作を確認します。

デプロイメント作成後にネットワークを変更することはできません。フィールドの詳細説明やネットワークオプションについては、Create an EMQX Agents Deployment を参照してください。

デプロイメントの状態が Running に変わったら、デプロイメントをクリックして開きます。

ステップ 2: コネクターの追加 ​

エージェントが MQTT トピックをサブスクライブしたりメッセージをパブリッシュしたりする前に、EMQX Broker を指すコネクターを構成する必要があります。

  1. EMQX Agents デプロイメントで、左メニューの Connectors をクリックします。

  2. Available タブで EMQX Broker を見つけ、Add をクリックします。

  3. Add Connector パネルで以下を入力します：

    • Type: EMQX Broker が自動入力されます。
    • Name: 例として factory-broker などの名前を入力します。
    • Address: host:port 形式でブローカーのアドレスを入力します。必ずポート番号を含めてください。例：暗号化なし MQTT は broker.example.com:1883、TLS は broker.example.com:8883。アドレスは EMQX Broker デプロイメントの概要ページの MQTT Connection Information セクションで確認できます。
    • Username と Password: EMQX Broker デプロイメントの Access Control -> Authentication で設定した認証情報を入力します。
    • Client ID Prefix: 空欄のままにします。システムが自動でクライアントIDを生成します。
    • このガイドでは Enable TLS/SSL はオフ、Default QoS は 1 のままにします。

  4. Confirm をクリックします。

コネクターは Added タブに表示され、Description 列にアドレスが表示されます。

コネクターの追加

ステップ 3: チャットを開始しエージェントを記述する ​

エージェントは会話を通じて構築されます。やりたいことを記述すると、LLM がエージェント定義を生成します。

  1. 左メニューの Chats をクリックし、+ New Chat をクリックします。

  2. 入力エリア左下のコネクターアイコンをクリックします。Connectors パネルが表示され、構成済みのコネクターが一覧表示されます。factory-broker をチェックしてこのセッションで利用可能にします。

    チャット用に EMQX Broker コネクターを選択

  3. 左下のツール承認セレクターで Always ask を選択します。このモードでは、デプロイや承認が必要なツール操作の前に EMQX Agents が確認を求めます。利用可能なモードの詳細は Select a Tool Approval Mode を参照してください。

  4. 入力欄にエージェントにやってほしいことを記述します。例として以下を入力してください：

    I want to monitor MQTT temperature events on the topic factory/+/+/temperature.
Each message payload is JSON, for example: {"device_id": "dev-0042", "temp": 95.4}
The agent should track the last 3 readings per device. If the rolling average
exceeds 70, publish an alert to alerts/anomaly.

  5. [任意] Add File アイコンをクリックして、スクリーンショットやサンプルペイロード、UTF-8 テキストファイルを添付し、LLM に追加のコンテキストを提供できます。1つのチャットメッセージには最大3つの添付ファイルを含められ、各ファイルは 2 MiB 以下でなければなりません。詳細は Add Attachments を参照してください。

  6. [任意] 右下のセレクターから、このリクエストに使用するモデルと推論の強度を選択します。詳細は Select a Model and Reasoning Effort を参照してください。

  7. 送信ボタンをクリックします。

LLM がリクエストを処理し、ローリング温度履歴を維持するスキルを作成し、MQTT トリガーとパブリッシュツールが構成された完全なエージェント定義を組み立てます。

ステップ 4: エージェントのデプロイ ​

Builder がエージェント定義を生成し検証すると、チャット下部に Review Agent が表示されます。

  1. 生成された定義を確認します。トリガー、閾値、アラートトピック、生成されたスキルが要件に合わない場合は、フォローアップの質問や変更依頼を行います。

  2. Review Agent をクリックして右側のレビュー パネルを開きます。

  3. 必須の Agent Name、任意の Description、Model and reasoning、Trigger、Instructions、Tools を確認します。パネルはチャットで選択したモデルと推論強度を初期設定として使用します。必要に応じて設定を編集してください。

    温度異常モニターのデプロイ前レビュー

  4. Deploy Agent をクリックします。

  5. Confirm deployment? ダイアログで Confirm をクリックします。これはチャットで Always ask を選択したための追加確認です。

  6. エージェントの作成が開始され、エージェント詳細ページが開きます。

数分後にエージェントの状態が Running になるのを確認できます。4つのタブ（Overview、Runs、Configuration、Skills）にデプロイされたエージェントとそのワークスペースが表示されます。

  • Configuration: エージェントの指示、MQTT トリガー、mqtt.publish ツールが生成されています。トリガーはトピックフィルター factory/+/+/temperature、QoS 1、factory-broker コネクターを使用します。パブリッシュツールは alerts/anomaly に制限されています。
  • Skills: デプロイされたエージェントにバンドルされた生成スキルとサポートファイルです。ローリング温度履歴を維持し、アラートをパブリッシュするタイミングを判断します。これらのファイルは左ナビゲーションメニューの Skills で管理される デプロイメントレベルのスキル とは別です。

デプロイ済みエージェントの設定をレビュー

ステップ 5: エージェントのテスト ​

テストメッセージを連続してパブリッシュし、エージェントが正しく動作するか確認します。

  1. MQTT クライアントを開き、同じ認証情報で同じ EMQX Broker に接続します。

  2. factory/+/+/temperature にマッチするトピック（例：factory/plant-a/line-3/temperature）に複数のメッセージをパブリッシュします。JSON ペイロードの例：

    json
    {"device_id": "dev-0022", "temp": 75.1}

    70 を超える温度で少なくとも3回パブリッシュします（例：75.1、78.3、80.0）。これによりエージェントは閾値を超えるローリング平均を計算できます。

  3. EMQX Agents デプロイメントに戻り、エージェントの Runs タブを開きます。

    トリガートピックにマッチした各メッセージが1つの実行を作成します。完了した実行は Succeeded ステータスを示します。

  4. 実行 ID をクリックして実行詳細ページを開きます。Timeline にその実行のイベントシーケンスが表示されます。

    イベント説明
    TRIGGER実行を開始した MQTT メッセージ（トピック含む）
    BUNDLE LOADEDエージェントのスキルと設定が読み込まれた
    CONTEXT LOADED会話コンテキストが準備された
    TOOLS RESOLVEDこの実行で利用可能なツールが解決された
    SYSTEM INITエージェントの指示が適用された
    TOOL RESULTエージェントが呼び出した各ツール（例：read、run_script、mqtt.publish）
    LLM CALLLLM の呼び出し（入力・出力トークン数付き）
    RESPONSEこの実行に対するエージェントの最終応答
    RUN END実行の最終ステータス

    ローリング平均閾値を超えた場合、mqtt.publish ツールの結果がタイムラインに表示され、Response イベントでアラートがパブリッシュされたことが確認できます。

エージェント実行のタイムライン

オプション: MCP コネクターを使ったエージェントの構築 ​

MCP コネクターを使うと、エージェントやチャットが Model Context Protocol (MCP) を通じて外部サービスを利用できます。

Slack などの外部サービスを使うエージェントを構築したい場合は、このオプションのフローを使います。メインチュートリアルの MQTT 温度モニターとは異なるリクエストのため、別のチャットを使います。

ステップ 1: MCP コネクターの追加 ​

  1. EMQX Agents デプロイメントで、左メニューの Connectors をクリックします。

  2. Available タブで MCP コネクターサービスとして Slack を見つけます。

  3. コネクターカードの Add をクリックします。

  4. Add Connector パネルでコネクターの Name を入力します（例：ops-slack）。Type フィールドは選択したサービスで自動入力され、他の設定フィールドは不要です。

  5. Confirm をクリックします。

MCP コネクターの追加

コネクターは Unauthorized 状態で追加され、EMQX Agents が選択したサービスの認可ダイアログを開きます。外部認可フローを完了してください。認可が成功すると、Added タブのコネクター状態が Authorized に変わります。

ダイアログを閉じるか認可が失敗した場合は、Added タブに戻り、該当コネクターの認可再試行アクションをクリックしてください。

ステップ 2: MCP コネクターを使ったチャットの開始 ​

  1. 左メニューの Chats をクリックし、+ New Chat をクリックします。

  2. 入力エリア左下のコネクターアイコンをクリックします。

  3. Connectors パネルで作成した MCP コネクターを選択します。

    例では MQTT イベントと Slack 通知を使うため、factory-broker と認可済みの Slack コネクターの両方を選択します。

    Authorized 状態の MCP コネクターのみ選択可能です。表示されていて無効の場合は、Connectors ページに戻り認可を完了または再試行してください。

    MCP コネクターを選択したチャットパネル

  4. 以下のリクエストを入力します：

    Listen to MQTT topic /devices/#. If the temperature in the MQTT message
is above 30, please send a warning message to Slack. Channel: <channel-name>.

    <channel-name> は通知したい Slack チャンネル名に置き換えてください。

  5. ツール承認モードを選択します。ガイド付きデプロイフローには Always ask を選択してください。

  6. [任意] このリクエストに使用するモデルと推論強度を選択します。

  7. 送信ボタンをクリックします。

LLM が選択した MCP コネクターのツールを含むエージェント定義を生成します。

ステップ 3: MCP エージェントのデプロイ ​

  1. 生成された定義が準備できたら Review Agent をクリックします。

  2. レビューパネルで Agent Name、Description、Model and reasoning、Trigger、Instructions、Tools を確認し、必要に応じて設定を更新します。

  3. Deploy Agent をクリックします。

  4. チャットで Always ask を使っている場合は、Confirm deployment? ダイアログで Confirm をクリックします。

  5. エージェント詳細ページを開き、Configuration と Skills タブで生成されたエージェントが選択した MCP コネクターを使い、リクエストされた動作を実装していることを確認します。

ステップ 4: MCP エージェントのテスト ​

チャットリクエストに記載された MQTT トピックと Slack アクションに従って MCP エージェントをテストします。このテストフローはメインチュートリアルの温度異常モニターとは異なります。

  1. MQTT クライアントで /devices/# にマッチするトピック（例：/devices/device-001）にテストメッセージをパブリッシュします。

    json
    {"device_id": "device-001", "temperature": 31}

  2. リクエストで指定した Slack チャンネルに警告メッセージが届いているか確認します。

  3. EMQX Agents に戻り、実行詳細ページを開きます。MCP コネクター呼び出しは実行タイムラインのツール結果として表示され、最終 Response イベントで結果が要約されます。

次にやること ​