MQTT

MQTT（Message Queuing Telemetry Transport、メッセージキュー・テレメトリ輸送）は、軽量で、パブリッシュ/サブスクライブ方式に基づくメッセージ転送プロトコルです。低帯域幅、高遅延、または信頼性の低いネットワーク環境向けに設計されており、IoT（モノのインターネット）、モバイルアプリケーション、分散システムで広く利用されています。機器間の効率的な通信を実現するために、データ転送量を抑えつつ通信フローを簡素化し、メッセージの信頼性の高い転送を確保します。また、さまざまなサービス品質（QoS）レベルをサポートしており、異なる業務要件に対応できます。

インストールと設定¶

• MQTT ブローカー（Broker）

Guance は Func を通じて MQTT プロトコルのデータを受信できます。

Func のインストール¶

Guance の統合 - 拡張 - マネージド版 Func を有効化することを推奨します。前提条件はすべて自動でインストールされるため、そのままスクリプトのインストールを続けてください。

Func を自己デプロイする場合はFunc の自己デプロイを参照してください。

GSE 版のデプロイを推奨します

Func ではすでに MQTT データソースとの連携が実装されています。以下の手順で接続してください。

• 1 スクリプトを作成する

Func 上でスクリプトを作成し、MQTT のデータを処理します。

import json

@DFF.API('Message Handler')
def message_handler(topic, message):
    print(f"Received message: {message} on topic {topic}")

スクリプトの作成が完了したら、[公開] ボタンをクリックします。

• 2 MQTT コネクタを設定する

①種類としてMQTT Broker (v5.0)を選択します

②ID、ホスト、ポートを入力します

③トピックと、対応するトピックを処理するスクリプトを指定します

④接続テストをクリックして、MQTT が正常に接続できることを確認します

⑤保存をクリックします