본문 바로가기
카테고리 없음

파이썬과 MQTT로 스마트 IoT 기기 완벽 제어하기

hopergy42 2025. 4. 5. 16:40

Python과 MQTT 프로토콜로 IoT 기기 제어하기

사물인터넷(IoT)은 전 세계적으로 혁신을 가져오는 기술 중 하나로, 다양한 기기가 인터넷을 통해 서로 연결되고 상호작용할 수 있도록 합니다. 이 글에서는 IoT 기기를 제어하기 위해 널리 사용되는 프로토콜인 MQTT(Message Queuing Telemetry Transport)와 이를 활용하는 프로그래밍 언어인 Python에 대해 자세히 알아보겠습니다. 초보자도 이해할 수 있도록 기본 개념부터 시작하여 실습 예제까지 다루겠습니다.

IoT와 MQTT란 무엇인가?

사물인터넷(IoT)의 개념

사물인터넷은 물리적인 기기가 인터넷을 통해 데이터를 수집하고 전송하며, 서로 상호작용하는 시스템입니다. 이러한 기기들은 센서, 액추에이터 등이 포함되어 있으며, 다양한 분야에서 활용되고 있습니다. 예를 들어, 스마트 홈, 헬스케어, 산업 자동화 등에서 사용됩니다.

MQTT 프로토콜의 정의

MQTT는 경량의 메시지 전송 프로토콜로, 주로 저전력 및 저대역폭의 환경에서 효율적으로 작동하도록 설계되었습니다. 이 프로토콜은 클라이언트와 브로커 간의 간단한 통신 구조를 제공하여 연결된 기기 간의 메시지 전송을 용이하게 합니다.

MQTT의 특징

  • 경량 프로토콜: MQTT는 간단한 헤더 구조로 되어 있어 전송 데이터의 양이 적습니다.
  • 게시/구독 모델: 클라이언트는 브로커에 메시지를 게시하거나 특정 주제의 메시지를 구독하여 수신할 수 있습니다.
  • 신뢰성: QoS(Quality of Service) 레벨을 설정하여 메시지 전송의 신뢰성을 조절할 수 있습니다.

Python으로 MQTT 다루기

Python 환경 설정하기

Python을 사용하여 MQTT를 제어하기 위해 먼저 Python 환경을 설정해야 합니다. Python 3.x 버전을 설치하신 후, 필요한 라이브러리를 설치해야 합니다. 가장 많이 사용되는 MQTT 클라이언트 라이브러리는 Paho-MQTT입니다.

Python 설치 방법

Python을 설치하는 방법은 다음과 같습니다.

  1. Python 공식 웹사이트(python.org)에 접속하여 최신 버전을 다운로드합니다.
  2. 설치 파일을 실행하여 설치 과정을 완료합니다.

Paho-MQTT 라이브러리 설치

라이브러리를 설치하기 위해 터미널 또는 명령 프롬프트에서 다음 명령어를 입력합니다.

pip install paho-mqtt

MQTT 기본 코드 구현

MQTT를 사용하기 위한 기본적인 Python 코드를 구현해 보겠습니다. 이 코드는 간단한 기기를 제어하는 예제입니다.

MQTT 브로커 설정

MQTT 브로커를 사용하기 위해 여러 종류의 브로커를 선택할 수 있습니다. 가장 많이 쓰이는 브로커로는 Mosquitto와 HiveMQ가 있습니다. Mosquitto 브로커를 설치해 보겠습니다.

기본 코드 예제

아래는 MQTT를 사용한 간단한 퍼블리셔(Publisher)와 서브스크라이버(Subscriber)의 예제 코드입니다.

import paho.mqtt.client as mqtt

MQTT 브로커 정보

broker = "mqtt.eclipse.org"
port = 1883
topic = "iot/test"

메시지를 받을 때 호출되는 콜백 함수

def on_message(client, userdata, message):
    print("메시지 수신: ", str(message.payload.decode("utf-8")))

MQTT 클라이언트 설정

client = mqtt.Client()
client.onmessage = onmessage

브로커에 연결

client.connect(broker, port)

서브스크립션

client.subscribe(topic)

메시지 발행

client.publish(topic, "안녕하세요, IoT!")

메시지 대기

client.loop_forever()

코드 설명

위 코드의 주요 부분에 대해 설명하겠습니다.

  • 브로커 및 포트 설정: MQTT 브로커의 주소와 포트를 설정합니다.
  • 콜백 함수: 메시지를 받았을 때 호출되는 함수를 정의하여 수신된 메시지를 출력합니다.
  • 클라이언트 생성: MQTT 클라이언트를 생성하고, 브로커에 연결합니다.
  • 서브스크립션 및 발행: 특정 주제를 구독하고 메시지를 발행합니다.
  • 루프: 클라이언트가 메시지를 대기하도록 합니다.

예제: 온도센서 데이터 전송

온도센서와 연동하기

이번에는 온도센서를 사용하여 MQTT 프로토콜을 통해 데이터를 전송하는 예제를 만들어 보겠습니다. 온도센서로는 DHT11 센서를 사용할 수 있습니다.

필요한 부품

  • Raspberry Pi 또는 Arduino
  • DHT11 온도센서
  • 점퍼 케이블

하드웨어 연결

DHT11 센서를 Raspberry Pi에 아래와 같이 연결합니다.

센서 핀 Raspberry Pi 핀
VCC 3.3V
GND GND
DATA GPIO 17

코드 작성

온도 데이터를 읽어 MQTT로 전송하는 코드는 아래와 같습니다.

import paho.mqtt.client as mqtt
import Adafruit_DHT
import time

MQTT 브로커 설정

broker = "mqtt.eclipse.org"
port = 1883
topic = "iot/temperature"

DHT11 설정

sensor = Adafruit_DHT.DHT11
pin = 17

client = mqtt.Client()
client.connect(broker, port)

while True:

온도 및 습도 읽기

    humidity, temperature = AdafruitDHT.readretry(sensor, pin)
    
    if temperature is not None:

온도 데이터 전송

        client.publish(topic, f"온도: {temperature}도")
        time.sleep(10)

10초 대기

실행 및 확인

작성한 코드를 실행하면, DHT11 센서에서 온도 데이터를 읽어 MQTT 브로커를 통해 전송합니다. 다른 클라이언트를 통해 해당 주제를 구독하면 온도 데이터를 실시간으로 확인할 수 있습니다.

MQTT의 활용 사례

스마트 홈

MQTT는 스마트 홈 시스템에 매우 유용하게 활용됩니다. 예를 들어, 조명 제어, 온도 조절 시스템 등 다양한 기기를 MQTT를 통해 제어할 수 있습니다.

산업 자동화

산업 현장에서 기계와 센서 간의 효율적인 데이터 교환을 위해 MQTT를 사용하여 실시간 모니터링 및 원격 제어 등을 수행할 수 있습니다.

헬스케어

IoT 헬스케어 기기에서 환자의 생체 신호를 수집하고 전송하는 데 MQTT를 활용할 수 있습니다. 이를 통해 의료 전문가는 실시간 데이터에 접근할 수 있습니다.

결론

본 기사를 통해 Python과 MQTT 프로토콜을 이용하여 IoT 기기를 제어하는 방법에 대해 알아보았습니다. IoT 기술은 빠르게 발전하고 있으며, MQTT는 그 중에서도 중요한 역할을 하고 있습니다. 초보자라도 기본적인 개념과 예제를 통해 MQTT를 활용하여 다양한 프로젝트를 진행할 수 있습니다. 앞으로도 지속적으로 이와 같은 기술을 학습하여 나만의 IoT 프로젝트를 구현해 보시기 바랍니다.

티스토리툴바