MQTT

MQTT(Message Queuing Telemetry Transport, 메시지 큐 원격 측정 전송 프로토콜)는 경량의 발행/구독 기반 메시지 전송 프로토콜로, 저대역폭, 고지연 또는 불안정한 네트워크 환경을 위해 설계되었으며, IoT(사물인터넷), 모바일 애플리케이션, 분산 시스템에서 기기 간의 효율적인 통신을 구현하는 데 널리 사용됩니다. 데이터 전송량을 줄이고 통신 절차를 단순화함으로써 메시지의 안정적인 전달을 보장하며, 다양한 서비스 품질(QoS) 등급을 지원하여 서로 다른 비즈니스 요구를 충족합니다.

설치 및 설정¶

• MQTT 브로커(Broker)

Guance는 Func를 통해 MQTT 프로토콜의 데이터를 수신할 수 있도록 지원합니다.

Func 설치¶

Guance 통합 - 확장 - 호스팅 버전 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가 정상적으로 연결되는지 확인합니다

⑤ 저장을 클릭하면 됩니다