AI 시대를 위한
차세대 IoT 플랫폼

# Neuriot MQTT 디바이스 연결
import neuriot

# 클라이언트 초기화
client = neuriot.Client(
    host="broker.neuriot.net",
    port=8883,
    device_id="sensor-001",
    api_key="nr_live_xxxxxxxxxxxx"
)

# TLS 연결 설정
client.configure_tls(
    certfile="device.crt",
    keyfile="device.key"
)

# 연결 이벤트 핸들러
@client.on_connect
def on_connect(rc):
    print(f"✓ 연결 성공: {rc}")

client.connect()

# 텔레메트리 데이터 발행
import neuriot, json, time

client = neuriot.Client(...)
client.connect()

while True:
    # 센서 데이터 읽기
    payload = {
        "temperature": read_sensor(),
        "humidity": read_humidity(),
        "timestamp": time.time(),
        "device_id": "sensor-001"
    }

    # QoS 1로 안전하게 발행
    client.publish(
        topic="devices/sensor-001/telemetry",
        payload=json.dumps(payload),
        qos=1
    )
    time.sleep(5)

# 명령 구독 및 처리
import neuriot, json

client = neuriot.Client(...)
client.connect()

# 명령 수신 핸들러
@client.on_message(
    topic="devices/+/commands"
)
def handle_command(msg):
    cmd = json.loads(msg.payload)

    if cmd["action"] == "restart":
        restart_device()
    elif cmd["action"] == "update_config":
        apply_config(cmd["payload"])

    # 실행 결과 응답
    client.publish(
        topic="devices/sensor-001/ack",
        payload='{"status": "ok"}'
    )

client.loop_forever()