MQTT を使って HDMI スイッチャーをシリアル通信で制御 | インターネット経由で遠隔操作可能な HDMI 切替器(HDMI スイッチャー)の開発（第2弾）

import evdev
import paho.mqtt.client as mqtt
import json

# MQTTブローカーの設定
MQTT_BROKER = 'xxxx1234.ala.asia-southeast1.emqxsl.com'
MQTT_PORT = 8883
MQTT_TOPIC = 'keyboard/switch'
MQTT_USER = 'zero-1'
MQTT_PASSWORD = 'password'
MQTT_CAFILE = '/home/pi/emqxsl-ca.crt'

# MQTTクライアントの設定
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASSWORD)
client.tls_set(MQTT_CAFILE, tls_version=mqtt.ssl.PROTOCOL_TLSv1_2)
client.connect(MQTT_BROKER, MQTT_PORT, 60)

# デバイスのevent番号を指定（キーボードのイベントデバイス）
device = evdev.InputDevice('/dev/input/event0')

# キーボードイベントの読み取りと送信
try:
    for event in device.read_loop():
        if event.type == evdev.ecodes.EV_KEY:
            if event.value == 1:  # キーが押された
                if event.code in [2, 3, 4, 5]:  # 1, 2, 3, 4キー
                    # データの送信 (JSON形式)
                    data = json.dumps({'code': event.code})
                    client.publish(MQTT_TOPIC, data)
                    print(f"Sent: {data}")  # 送信したデータを表示
except Exception as e:
    print(f"An error occurred: {e}")
finally:
    client.disconnect()

ls /dev/ttyUSB*

import paho.mqtt.client as mqtt
import json
import serial

# MQTTブローカーの設定
MQTT_BROKER = 'xxxx1234.ala.asia-southeast1.emqxsl.com'
MQTT_PORT = 8883
MQTT_TOPIC = 'keyboard/switch'
MQTT_USER = 'zero-2'
MQTT_PASSWORD = 'password'
MQTT_CAFILE = '/home/pi/emqxsl-ca.crt'

# シリアルポートの設定（ttyUSB0を使用）
ser = serial.Serial('/dev/ttyUSB0', 57600, timeout=1)

# シリアル信号を送る関数
def send_command(x, y):
    command = f'EZS OUT{x} VS IN{y}\r\n'
    ser.write(command.encode())
    print(f'Sent: {command}')

# MQTTメッセージのコールバック関数
def on_message(client, userdata, msg):
    try:
        obj = json.loads(msg.payload)
        code = obj['code']
        if code == 2:  # '1'キー
            send_command(1, 1)
        elif code == 3:  # '2'キー
            send_command(1, 2)
        elif code == 4:  # '3'キー
            send_command(1, 3)
        elif code == 5:  # '4'キー
            send_command(1, 4)
        print(f"Received: {obj}")
    except json.JSONDecodeError:
        pass

# MQTTクライアントの設定
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASSWORD)
client.tls_set(MQTT_CAFILE, tls_version=mqtt.ssl.PROTOCOL_TLSv1_2)
client.on_message = on_message

# MQTTブローカーに接続し、トピックを購読
client.connect(MQTT_BROKER, MQTT_PORT, 60)
client.subscribe(MQTT_TOPIC)

# メインループ
try:
    print("Waiting for MQTT messages...")
    client.loop_forever()
except KeyboardInterrupt:
    client.disconnect()
    ser.close()
    print("終了しました。")