MQTTコネクタ

概要

MQTTコネクタは、MQTT v3プロトコルを使用してIoTデバイスのパブリッシュ/サブスクライブメッセージングを可能にします。

コネクタタイプ:

• MqttV3Reader - MQTTトピックをサブスクライブ
• MqttV3Writer - MQTTトピックにパブリッシュ

MQTT Reader

MQTTトピックをサブスクライブしてメッセージを受信：

{
  "type": "MqttV3Reader",
  "config": {
    "endpoint": "localhost:1883",
    "topic": "sensors/temperature",
    "qos": 0,
    "clientId": "meddle-reader"
  }
}

認証あり

{
  "type": "MqttV3Reader",
  "config": {
    "endpoint": "mqtt.example.com:1883",
    "topic": "factory/sensors/#",
    "qos": 1,
    "clientId": "meddle-reader",
    "username": "mqtt_user",
    "password": "mqtt_password"
  }
}

MQTT Writer

MQTTトピックにメッセージをパブリッシュ：

{
  "type": "MqttV3Writer",
  "config": {
    "endpoint": "localhost:1883",
    "topic": "data/output",
    "qos": 0,
    "clientId": "meddle-writer"
  }
}

設定パラメータ

• endpoint: MQTTブローカーアドレス（host:port）
• topic: サブスクリプション/パブリッシュ用のトピック（リーダーのワイルドカードをサポート：+、#）
• qos: Quality of Service（0、1、または2）
• clientId: 一意のクライアント識別子
• username: （オプション）MQTTユーザー名
• password: （オプション）MQTTパスワード

QoSレベル

• 0: 最大1回（fire and forget）
• 1: 少なくとも1回（確認された配信）
• 2: 正確に1回（保証された配信）

トピックワイルドカード（リーダーのみ）

• +: 単一レベルワイルドカード（sensors/+/temperature）
• #: マルチレベルワイルドカード（sensors/#）

関連コネクタ

• HTTP - REST API代替
• Filter - MQTTメッセージをフィルタリング