コネクター
コネクターは外部システムへのアクセスを提供し、エージェントやチャットが実行中に使用できるアクション（MQTTメッセージのパブリッシュ、時系列テーブルのクエリ、MCPサービスの利用など）を公開します。
EMQX Agents は以下のコネクタータイプをサポートしています。
| タイプ | 説明 |
|---|---|
| EMQX Fleets | EMQX Fleetsのデバイスレジストリおよび関連するデバイス管理機能を操作します。 |
| EMQX Broker | MQTTトピックをイベントトリガーとしてサブスクライブし、アクションとしてメッセージをパブリッシュします。 |
| EMQX Tables | SQLを通じて時系列データのクエリと書き込みを行います。 |
| MCPコネクター | Model Context Protocol（MCP）を通じて外部サービスを認可し、承認されたMCPツールをエージェントに公開します。現在はGmailとSlackをサポートしており、今後さらにMCPコネクターサービスが追加される予定です。 |
コネクターはデプロイメントレベルで設定され、複数のエージェントやチャットで再利用できます。
コネクターの表示
デプロイメントの左メニューでConnectorsをクリックすると、コネクターページが開きます。このページには2つのタブがあります。
- Available：追加可能なコネクタータイプ（EMQX Fleets、EMQX Broker、EMQX Tables、MCPコネクター）を表示します。検索ボックスでコネクタータイプを絞り込めます。
- Added：すでにデプロイメントに追加されたコネクターを表示します。検索ボックスで名前による絞り込みが可能です。
Added タブには設定済みコネクターが以下の列で表示されます。
| 列 | 説明 |
|---|---|
| Name | コネクターに割り当てられた表示名。 |
| Type | コネクタータイプ（EMQX Fleets、EMQX Broker、EMQX Tables、MCPコネクターサービスなど）。 |
| Authorization | 認可ステータス。MCPコネクターはUnauthorized、Authorized、Expired、Errorを表示可能。 |
| Description | 接続の概要。MCPコネクターはトランスポートと認可の詳細を表示。 |
| Updated At | 最終更新日時。 |
| Actions | 認可の再試行、編集、削除。認可が必要なMCPコネクターには認可再試行アクションが表示されます。 |
コネクターの追加
- 左メニューのConnectorsをクリックします。
- Availableタブで追加したいコネクタータイプを探します。
- コネクターカードのAddをクリックします。
- Add Connectorパネルで必要項目を入力します。
- Confirmをクリックします。
チャットからもコネクターを追加可能です。チャットの入力エリアでコネクターアイコンをクリックし、Connectorsパネルの**+をクリックすると、Add Connectorパネルが開き、Choose Connector TypeステップとConfiguration**ステップが表示されます。
EMQX Fleets
EMQX Fleetsのデバイスレジストリおよび関連デバイス管理機能を操作するためのコネクタータイプです。
| フィールド | 必須 | 説明 |
|---|---|---|
| Type | はい | 選択されたコネクタータイプ、EMQX Fleets。 |
| Name | はい | コネクターの表示名（例：factory-fleets）。 |
| API Endpoint | はい | Fleets APIのエンドポイント（例：https://example.fleets.mqttce.net:8443）。 |
| API Key | はい | Fleets API認証に使用するAPIキー。 |
| API Secret | はい | Fleets API認証に使用するAPIシークレット。 |
| Timeout (seconds) | いいえ | リクエストのタイムアウト秒数。デフォルトは10。 |
| Verify TLS/SSL | いいえ | Fleets API接続時にTLS証明書を検証するか。デフォルトで有効。 |
EMQX Broker
EMQX Brokerデプロイメント上でMQTTトピックのサブスクライブとメッセージのパブリッシュを行うためのコネクタータイプです。
| フィールド | 必須 | 説明 |
|---|---|---|
| Type | はい | 選択されたコネクタータイプ、EMQX Broker。 |
| Name | はい | コネクターの表示名（例：factory-broker）。先頭は英字で、英数字、ハイフン、アンダースコアを含み、最大64文字。 |
| Address | はい | host:port形式のブローカーアドレス。必ずポート番号を含める。例：暗号化なしMQTTはbroker.example.com:1883、TLSはbroker.example.com:8883。EMQX Brokerデプロイメントの概要ページのMQTT Connection Informationで確認可能。 |
| Username | いいえ | ブローカー認証用のユーザー名。EMQX BrokerデプロイメントのAccess Control -> Authenticationで設定。 |
| Password | いいえ | ブローカー認証用のパスワード。 |
| Client ID Prefix | いいえ | このコネクターで使用するMQTTクライアントIDに付与するプレフィックス。ブローカーのログでエージェント接続を識別するのに便利。 |
| Enable TLS/SSL | いいえ | 接続にTLSを有効化。デフォルトは無効。 |
| Default QoS | いいえ | サブスクライブおよびパブリッシュのデフォルトMQTT QoSレベル。選択肢：0、1、2。デフォルトは1。 |
EMQX Tables
EMQX Tablesデプロイメントのデータをクエリおよび書き込みするためのコネクタータイプです。
| フィールド | 必須 | 説明 |
|---|---|---|
| Type | はい | 選択されたコネクタータイプ、EMQX Tables。 |
| Name | はい | コネクターの表示名（例：factory-tables）。 |
| Address | はい | host:port形式のTablesサービスアドレス。デフォルトポートは4000。ポート省略時は4000が使用されます。EMQX Tablesデプロイメントの概要ページのConnection Infoで確認可能。 |
| Username | いいえ | Tablesサービス認証用のユーザー名。概要ページのConnection Infoで確認可能。 |
| Password | いいえ | Tablesサービス認証用のパスワード。概要ページのConnection Infoで確認可能。 |
| Database Name | いいえ | 接続するデータベース名。デフォルトはpublic。 |
| Enable TLS/SSL | いいえ | 接続にTLSを有効化。デフォルトは無効。 |
MCPコネクター
Model Context Protocolを通じてエージェントやチャットが外部サービスと連携するためのコネクターです。
MCPコネクターはAdd Connectorパネルでサービス固有の設定を必要としません。パネルには選択されたTypeと必須のNameフィールドが表示され、認可が必要である旨の通知があります。Confirmをクリックすると、コネクターはUnauthorizedステータスで追加され、EMQX Agentsが選択されたサービスの認可ポップアップを開きます。
| フィールド | 必須 | 説明 |
|---|---|---|
| Type | はい | 選択されたMCPコネクターサービス（例：Gmail、Slack）。 |
| Name | はい | コネクターの表示名（例：support-gmail、ops-slack）。 |
TIP
チャットやエージェントでMCPコネクターを使用する前に、認可フローを完了してください。Authorized 状態のMCPコネクターのみチャットで選択可能です。
MCPコネクターの認可状態は以下の通りです。
| 状態 | 説明 | 対応 |
|---|---|---|
| Unauthorized | 認可が完了していない、または認可フローが完了前に閉じられた状態。 | Actions列の認可再試行をクリックして認可フローを再開。 |
| Authorized | 認可が成功し、コネクターがMCPツールをチャットやエージェントに公開可能。 | 対応不要。 |
| Expired | 外部サービスの認可が期限切れ。 | Actions列から再認可。 |
| Error | 認可に失敗したか、EMQX Agentsが認可状態を検証できない。 | 認可を再試行。状態がErrorのままなら外部サービスアカウントを確認し再試行。 |
Unauthorized、Expired、ErrorステータスのコネクターはチャットのConnectorsパネルに表示されることがありますが、選択できません。
コネクターの編集
- Connectorsページで更新したいコネクターのActions列にある編集アイコンをクリックします。
- Edit Connectorパネルで必要な項目を更新します。
- Confirmをクリックします。
重要
稼働中のエージェントで使用中のコネクターを編集すると即時反映されます。認証情報やアドレスが誤っていると、次回のエージェント実行が失敗します。
コネクターの削除
- Connectorsページで削除したいコネクターのActions列にある削除アイコンをクリックします。
- 削除を確認します。
重要
デプロイされたエージェントで使用中のコネクターは削除できません。先にエージェントを停止または削除してからコネクターを削除してください。
チャットでのコネクター利用
チャット開始時に、LLMがアクセス可能なコネクターを選択できます。これにより、LLMは適切なコネクターを参照してエージェント定義を生成できます。
チャットセッションでコネクターを選択する方法：
- 入力エリア左下のコネクターアイコンをクリックします。Connectorsパネルが開き、設定済みコネクターが一覧表示されます。
- 利用可能にしたい認可済みコネクターにチェックを入れます。Unauthorized、Expired、ErrorステータスのMCPコネクターはリストに表示される場合がありますが選択できません。
- 新しいコネクターを追加するには、パネル右上の**+**をクリックします。チャットを離れずにAdd Connectorフォームが開きます。
選択したコネクターは、LLMが生成するエージェント定義のトリガーやツールの設定に使用されます。例えば、EMQX Brokerコネクターを選択すると、LLMはそれをMQTTトリガーソースやmqtt.publishアクションのターゲットとして設定できます。MCPコネクターを選択すると、GmailやSlackなど外部サービスが公開するツールをエージェント定義生成時に利用可能です。