English

SINETStream ユーザガイド

MQTT固有のパラメータ

• clean_session
  • 再起動、再接続で状態を記憶するかどうか
• protocol
  • MQTTバージョン
  • 指定できる値は MQTTv31, MQTTv311, MQTTv5 のどれか
• transport
  • 指定できる値は tcp, websockets のどちらか
• qos
  • メッセージを送受信する際の QoS
  • 0, 1, 2 が指定でき、それぞれ Consistency の AT_MOST_ONCE, AT_LEAST_ONCE, EXACTLY_ONCE に対応する
  • Consistency の設定値より、qos の設定値が優先される
  • 指定されたqos の値は MessageReader, MessageWriter から getConsistency() で取得できる
• retain
  • サーバーがこのメッセージを保持するかどうか
• max_inflight_messages_set
  • 以下のパラメータを指定できる
    • inflight
      • ネットワークフローを一度に通過できる QoS > 0のメッセージの最大数
• ws_set_options
  • WebSocket接続のオプションを指定する
  • 以下のパラメータを指定できる
    • path
      • WebSocket のパスを指定する
    • headers
      • 標準の WebSocketヘッダーに追加するヘッダーをマッピングで指定する
• tls_set
  • TLS接続に関するパラメータをマッピングで指定する
  • 以下のパラメータを指定できる
    • ca_certs
      • CA証明書ファイル (PEM) のパス
    • certfile
      • クライアント証明書ファイル (PEM) のパス
    • keyfile
      • クライアント証明書の秘密鍵ファイル (PEM) のパス
    • keyfilePassword (*)
      • クライアント証明書の秘密鍵ファイル (PEM) のパスワード
    • tls_version
      • TLSプロトコルのバージョン
    • ciphers
      • この接続で許可する暗号
    • trustStore (*)
      • トラストストアのパス
    • trustStoreType (*)
      • トラストストアのファイルフォーマット (jks, pkcs12, …)
    • trustStorePassword (*)
      • トラストストアのパスワード
    • keyStore (*)
      • キーストアのパス
    • keyStoreType (*)
      • キーストアのファイルフォーマット (jks, pkcs12, …)
    • keyStorePassword (*)
      • キーストアのパスワード

        (*) trustStore, trustStoreType, trustStorePassword, keyStore, keyStoreType, keyStorePassword, keyfilePassword は Java APIのみで指定できるパラメータである。Python API では指定できない。

• tls_insecure_set
  • 以下のパラメータを指定できる
    • value
      • TLS接続でホスト名の検証を無視するかどうか
• username_pw_set
  • 認証用のユーザ、パスワードをマッピングで指定する
  • 以下のパラメータを指定する
    • username
    • password
• will_set
  • Last Will and Testament (LWT) に関するパラメータをマッピングで指定する
  • クライアントが予期せず切断された場合、ブローカーがLWTに設定されているメッセージを代わりに発行する
  • 以下のパラメータを指定できる
    • topic
    • payload
    • qos
    • retain
  • delay_interval (MQTTv5のみ)
• reconnect_delay_set
  • 再接続するまでの待機時間に関するパラメータをマッピングで指定する
  • 以下のパラメータを指定できる
    • max_delay
      • 最大待ち時間 (秒)
    • min_delay
      • 最小待ち時間 (秒)
• connect
  • 接続に関するパラメータをマッピングで指定する
  • 以下のパラメータを指定できる
    • keepalive
      • キープアライブの間隔 (秒) を指定する
    • automatic_reconnect (*)
      • 接続が切れた場合に、自動的に再接続を行うかどうか
    • connection_timeout (*)
      • 接続タイムアウト値 (秒) を指定する

        (*) automatic_reconnect, connection_timeout は Java APIのみで指定できるパラメータである。Python API では指定できない。

• receive_maximum (MQTTv5のみ)
  • デフォルト: 65Ki
  • QoS > 0 のときの同時処理数を制限する。
• maximum_packet_size (MQTTv5のみ)
  • デフォルト: no limit
  • readerの最大パケットサイズを制限する。
• topic_alias_maximum (MQTTv5のみ)
  • デフォルト: 0
  • readerのトピック・エイリイアスの数を制限する。
• request_response_info (MQTTv5のみ)
  • デフォルト: false
  • writerがreaderにリクエスト・レスポンス情報
• request_problem_info (MQTTv5のみ)
  • デフォルト: true
  • エラー時にReason Stringを返すがfalseに設定するとPUBLISH/CONNACK/DISCONNECでしか返さなくなる。
• user_property
  • ユーザープロパティを設定する。
• auth_method
  • デフォルト: null
• auth_data
  • デフォルト: null
  • 拡張認証データを設定する。
• clean_session (MQTTV3)
  • 再起動、再接続で状態を記憶するかどうか
• clean_start (MQTTv5のみ)
  • デフォルト: true
  • 再起動・再接続に備えてセッションを維持しないかどうか。
• session_expiry_interval (MQTTv5のみ)
  • デフォルト: null(無制限)
  • セッションを維持する時間(単位は秒)を指定する。
  • 0を指定するとコネクションが切れたらすぐにセッションが終了する。
• connect
  • max_reconnect_delay (Java&MQTTv5のみ)
    • デフォルト: 128000
    • 再接続の間隔の最大時間(単位はミリ秒)
  • use_subscription_identifiers (Java&MQTTv5のみ)
    • デフォルト: true
    • サブスクリプション識別子をつかうかどうか設定する。
  • send_reason_messages (Java&MQTTv5のみ)
    • デフォルト: false
    • エラー時にReason Stringプロパティを付けるかどうか。
• max_queued_messages_set (Pythonのみ)
  • queue_size
    • デフォルト: 0
    • 出力メッセージキューの最大長を設定する。
    • 0を設定すると無制限になる。

MQTTの設定例

MQTTでブローカーとの接続にTCPではなくWebSocketを使う場合は以下のようにtransportパラメータを設定する。

service-mqtt:
  type: mqtt
  brokers: mqtt.example.org
  transport: websockets