クイックスタート：最初のエージェントの構築とデプロイ
このガイドでは、EMQX Agents を使ってイベント駆動型のエージェントを作成する手順を説明します。工場のデバイスからの MQTT メッセージを監視し、各読み取り値をローリング平均と比較して、デバイスの平均温度が閾値を超えた場合にアラートをパブリッシュする温度異常モニターを構築します。
このガイドの最後には、以下を達成しています。
- EMQX Broker に接続された稼働中の EMQX Agents デプロイメント
- ブローカー用に設定されたコネクター
- ライブの MQTT イベントに反応するデプロイ済みエージェント
前提条件
- 有効なプロジェクトを持つ EMQX Cloud アカウント
- Running 状態の EMQX Broker デプロイメント。ブローカーは EMQX Agents デプロイメントと同じプロジェクトおよびリージョンにある必要があります。
- テストメッセージをパブリッシュするための MQTT クライアント（例：MQTTX）
ステップ 1：EMQX Agents デプロイメントの作成
EMQX Cloud コンソールにログインし、プロジェクトを開きます。
EMQX Agents カードの + New をクリックします。
New Deployment ページで：
- Starter プランがデフォルトで選択されています。
- Cloud Provider & Region では、EMQX Broker デプロイメントと同じプロバイダーおよびリージョンを選択します。
- Network Association では、ブローカーのデプロイメントと共有されているネットワークをドロップダウンから選択します。これにより、エージェントとブローカー間のプライベート接続が有効になります。
TIP
ドロップダウンにネットワークが表示されない場合、選択したリージョンに既存の EMQX Broker または EMQX Tables デプロイメントがありません。先にそれらを作成してからこのステップに戻ってください。
必要に応じて Deployment Name を入力します。
Deploy をクリックし、確認ダイアログで Confirm をクリックします。
デプロイメントの初期化には少し時間がかかります。準備ができたら、デプロイメントをクリックして開きます。
ステップ 2：コネクターの追加
エージェントが MQTT トピックをサブスクライブしたりメッセージをパブリッシュしたりする前に、EMQX Broker を指すコネクターを設定する必要があります。
EMQX Agents デプロイメントで、左メニューの Connectors をクリックします。
+ Add Connector をクリックします。
Add Connector パネルで：
- Type：自動的に
EMQX Brokerが入力されます。 - Name：例として
factory-brokerなどの名前を入力します。 - Address：
host:port形式でブローカーのアドレスを入力します。必ずポート番号を含めてください。例えば、暗号化なしの MQTT はbroker.example.com:1883、TLS はbroker.example.com:8883です。アドレスは EMQX Broker デプロイメントの Overview ページの MQTT Connection Information セクションで確認できます。 - Username と Password：EMQX Broker デプロイメントの Access Control -> Authentication で設定した認証情報を入力します。
- Client ID Prefix：空欄のままにします。クライアント ID はシステムが自動生成します。
- Enable TLS/SSL はオフ、Default QoS は
1のままにします（このガイドの設定）。
- Type：自動的に
Confirm をクリックします。
コネクターがリストに表示され、Description 列にアドレスが示されます。
ステップ 3：チャットを開始しエージェントを説明する
エージェントは会話を通じて構築されます。やりたいことを説明すると、LLM がエージェント定義を生成します。
左メニューの Chats をクリックし、+ New Chat をクリックします。
入力エリア左下のコネクターアイコンをクリックします。Connectors パネルが表示され、設定済みのコネクターが一覧で表示されます。
factory-brokerにチェックを入れて、このセッションで利用可能にします。
入力フィールドに、エージェントにやらせたいことを説明します。このガイドでは以下を入力してください。
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.右下のドロップダウンから希望の思考モードを選択し、送信ボタンをクリックします。
LLM がリクエストを処理し、エージェントの指示を生成します。ローリング温度履歴を管理するスキルを作成し、MQTT トリガーとパブリッシュツールを設定した完全なエージェント定義を組み立てます。
ステップ 4：エージェントをデプロイ
LLM がエージェント定義の生成を完了すると、チャット画面の下部に Deploy Agent ボタンが表示されます。
Deploy Agent をクリックします。
ダイアログが表示され、事前入力された Agent Name と Description が表示されます。必要に応じて編集し、Deploy Agent をクリックします。
エージェントの作成が即座に開始され、エージェント詳細ページに遷移します。
数分後、エージェントのステータスが Running になります。以下の5つのタブ（Overview, Runs, Trigger, Tools, Prompt）で、チャットから生成された完全な設定を確認できます。
- Trigger：種類は
mqtt、トピックはfactory/+/+/temperature、QoS は1、factory-brokerコネクターに接続。 - Tools：
mqtt.publish、alerts/anomalyトピックに制限。 - Prompt：LLM がこのエージェント用に作成した指示で、各イベントの振る舞いを説明。
ステップ 5：エージェントのテスト
テストメッセージを連続してパブリッシュし、エージェントが正しく動作するか確認します。
MQTT クライアントを開き、同じ認証情報で同じ EMQX Broker に接続します。
factory/+/+/temperatureにマッチするトピック、例えばfactory/plant-a/line-3/temperatureに複数のメッセージをパブリッシュします。ペイロードは JSON 形式で：json{"device_id": "dev-0022", "temp": 75.1}温度が 70 を超える値（例：
75.1、78.3、80.0）で少なくとも3回パブリッシュしてください。これによりエージェントはローリング平均を計算し、閾値超過を検知できます。EMQX Agents デプロイメントに戻り、エージェントの Runs タブを開きます。
トリガートピックにマッチした各メッセージで実行が作成され、各実行は success ステータスを表示します。
実行 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 イベントでアラートがパブリッシュされたことが確認できます。
次にやること
- EMQX Tables コネクターを追加 して、エージェント内から時系列データのクエリや書き込みを行う。
- エージェントの管理 で実行履歴の監視、タイムラインの検査、動作更新による再デプロイを行う。
- コネクターの更新 で認証情報の変更や追加ブローカーへの接続を設定する。