Raspberry Pi Pico 2W＋有線LANを使ったMQTTサブスクライブ

Details

はじめに

Raspberry Pi 2WはWiFiモジュールが付いているので無線通信が簡単にできて便利です．その一方で多くの無線が飛び交う環境下では混線により通信障害が起こる可能性があります．ここではRaspberry Pi 2WにW5500を接続して有線LANを可能にし，MQTTによりサブスクライブできるまでの設定について説明します．

環境

Raspberry Pi Pico 2WのIPアドレスを192.168.100.251，BrokerのIPアドレスを192.168.100.250として同一セグメント下にそれぞれを接続しました．

必要なライブラリ

W5500 Ethernetモジュールを使用できるまでの設定についてはこちらにありますのでご覧ください．ここではその続きから説明します．下記ライブラリをPicoのlibへ追加します．これらもすべてcircuitpythonのサイトからダウンロードしたものです．

  • adafruit_minimqttフォルダ
  • adafruit_connection_manager.mpyファイル

Pythonのコード

下記コードでサブスクライブできました．

import board
import busio
import digitalio
import time
from adafruit_wiznet5k.adafruit_wiznet5k import WIZNET5K
import adafruit_minimqtt.adafruit_minimqtt as MQTT
import adafruit_connection_manager
import socketpool

SPI0_SCK = board.GP18
SPI0_TX = board.GP19
SPI0_RX = board.GP16
SPI0_CSn = board.GP17
W5500_RSTn = board.GP20

print("Wiznet5k Ping Test (no DHCP)")

# Setup your network configuration below
# random MAC, later should change this value on your vendor ID
#MY_MAC = (0x00, 0x01, 0x02, 0x03, 0x04, 0x05)
MY_MAC = '0x00:0x01:0x02:0x03:0x04:0x05'
IP_ADDRESS = (192, 168, 200, 251)
SUBNET_MASK = (255, 255, 255, 0)
GATEWAY_ADDRESS = (192, 168, 200, 1)
DNS_SERVER = (8, 8, 8, 8)

MQTT_BROKER="１92.168.200.250"
MQTT_PORT=1883
MQTT_CLIENT_ID="XXXXXXX"
MQTT_CLIENT_PASSWORD="XXXXXXXXX"

led = digitalio.DigitalInOut(board.LED)
led.direction = digitalio.Direction.OUTPUT

ethernetRst = digitalio.DigitalInOut(W5500_RSTn)
ethernetRst.direction = digitalio.Direction.OUTPUT

# For Adafruit Ethernet FeatherWing
cs = digitalio.DigitalInOut(SPI0_CSn)
# For Particle Ethernet FeatherWing
# cs = digitalio.DigitalInOut(board.D5)
spi_bus = busio.SPI(SPI0_SCK, MOSI=SPI0_TX, MISO=SPI0_RX)

# Reset W5500 first
ethernetRst.value = False
time.sleep(1)
ethernetRst.value = True

# Initialize ethernet interface with DHCP
# eth = WIZNET5K(spi_bus, cs)
# Initialize ethernet interface without DHCP
eth = WIZNET5K(spi_bus, cs, is_dhcp=False, mac=MY_MAC)

# Set network configuration
#eth.ifconfig = (IP_ADDRESS, SUBNET_MASK, GATEWAY_ADDRESS, DNS_SERVER)

eth.ifconfig = (IP_ADDRESS, SUBNET_MASK, GATEWAY_ADDRESS,(0,0,0,0))

print("Chip Version:", eth.chip)
print("MAC Address:", [hex(i) for i in eth.mac_address])
print("My IP address is:", eth.pretty_ip(eth.ip_address))

pool = adafruit_connection_manager.get_radio_socketpool(eth)

def connected(client, userdata, flags, rc):
    print("MQTT connected")
    client.subscribe("light")


def disconnected(client, userdata, rc):
    print("MQTT disconnected")


def receive_message(client, topic, message):
    print("MQTT message on topic {0}: {1}".format(topic, message))

mqtt_client = MQTT.MQTT(
    broker='192.168.200.250',
    port=1883,
    socket_pool=pool,
    #is_ssl=False,
    username='Light00',
    password='HaiRDetecTLighT00'
)

# Setup the callback methods above
mqtt_client.on_connect = connected
mqtt_client.on_disconnect = disconnected
mqtt_client.on_message = receive_message

# Connect the client to the MQTT broker.
print("MQTT connecting")
mqtt_client.connect()


while True:
    mqtt_client.loop()
    #mqtt_client.publish("light", "{\"key\": \"value\"}")
    #print("loop")
    #time.sleep(1)
    #time.sleep(1)
'''
    led.value = not led.value
    time.sleep(1)
'''
print("Done!")