1
2
3
4

# mqtt端口
listener 1883
# 用户名密码配置文件
password_file /etc/mosquitto/pwfile.example

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

import serial
import paho.mqtt.client as mqtt

ser = serial.Serial('/dev/ttyAMA2', 115200)  # Serial port name and baud rate
mqtt_client = mqtt.Client()
mqtt_client.username_pw_set('xxx', 'xxx')  # MQTT username and password


def on_connect(client, userdata, flags, rc):
    print('Connected to MQTT broker with result code ' + str(rc))


mqtt_client.on_connect = on_connect
mqtt_client.connect('xxx.xxx.xxx.xxx', 1883)  # MQTT server IP address and port number
mqtt_client.loop_start()
while True:
    data = ser.read(1024)  # Read serial data and decode it
    # print(data)  # Print data to console
    mqtt_client.publish('pi-test', data)  # Publish data to MQTT topic