如何将实时传感器数据从Raspberry Pi零发送到PC?
How to send real-time sensor data to PC from Raspberry Pi Zero?
我写了一个 Python3 脚本,它在 Raspberry Pi 零 W 上运行,它从 IMU 传感器 (MPU9250) 收集数据并创建 3 个不同的角度值;滚动,俯仰,偏航。看起来像这样:
def main():
while True:
dataAcc = mpu.readAccelerometerMaster()
dataGyro = mpu.readGyroscopeMaster()
dataMag = mpu.readMagnetometerMaster()
[ax, ay, az] = [round(dataAcc[0], 5), round(dataAcc[1], 5), round(dataAcc[2], 5)]
[gx, gy, gz] = [round(dataGyro[0], 5), round(dataGyro[1], 5), round(dataGyro[2], 5)]
[mx, my, mz] = [round(dataMag[0], 5), round(dataMag[1], 5), round(dataMag[2], 5)]
update(gx, gy, gz, ax, ay, az, mx, my, mz)
roll = getRoll()
pitch = getPitch()
yaw = getYaw()
print(f"Roll: {round(roll, 2)}\tPitch: {round(pitch, 2)}\tYaw: {round(yaw, 2)}")
我想做的是将这 3 个值发送到我的 PC 并读取它们。有什么办法可以发送这些数据。
(如果可能,除了 serial
)。
您可以在 pi 上设置一个简单的 Web 服务器,并从同一网络上的任何设备访问该服务器,而无需进行任何花哨的设置。
如果你的 pi zero 有 wifi 或者你可以获得适配器,你可以轻松地使用 flask 或 Django 启动你的服务器。
有很多方法可以做到这一点,仅举几例:
- 从 Raspi 向 PC 发送 UDP 消息
- 从 Raspi 向 PC 发送 TCP 流
- 将读数放入 Redis 并允许您网络上的任何人收集它们 - 例如
- 使用 MQTT 客户端从你的 Raspi 发布读数,并在你作为服务器的 PC 上订阅该主题
- 运行 a Python Multiprocessing Manager 在一台机器上并从另一台机器连接 - 请参阅 “使用远程管理器”。 =49=] here
- 通过蓝牙发送读数
下面是使用 UDP 实现上述第一个建议的可能方法。首先Raspi端产生3个读数X,Y,Z,每秒通过UDP发送给PC:
#!/usr/bin/env python3
import socket
import sys
from time import sleep
import random
from struct import pack
# Create a UDP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
host, port = '192.168.0.8', 65000
server_address = (host, port)
# Generate some random start values
x, y, z = random.random(), random.random(), random.random()
# Send a few messages
for i in range(10):
# Pack three 32-bit floats into message and send
message = pack('3f', x, y, z)
sock.sendto(message, server_address)
sleep(1)
x += 1
y += 1
z += 1
PC端匹配代码如下:
#!/usr/bin/env python3
import socket
import sys
from struct import unpack
# Create a UDP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# Bind the socket to the port
host, port = '0.0.0.0', 65000
server_address = (host, port)
print(f'Starting UDP server on {host} port {port}')
sock.bind(server_address)
while True:
# Wait for message
message, address = sock.recvfrom(4096)
print(f'Received {len(message)} bytes:')
x, y, z = unpack('3f', message)
print(f'X: {x}, Y: {y}, Z: {z}')
这是 MQTT 建议的一种可能实现方式。首先,发布这三个值的发布者。请注意,我的桌面上有 mosquitto
代理 运行ning:
#!/usr/bin/env python3
from time import sleep
import random
import paho.mqtt.client as mqtt
broker = '192.168.0.8'
client = mqtt.Client()
client.connect(broker,1883,60)
# Generate some random start values
x, y, z = random.random(), random.random(), random.random()
# Send a few messages
for i in range(10):
# Publish out three values
client.publish("topic/XYZ", f'{x},{y},{z}');
sleep(1)
x += 1
y += 1
z += 1
这是订阅者,它监听消息并打印它们:
#!/usr/bin/env python3
import socket
import sys
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("topic/XYZ")
def on_message(client, userdata, msg):
message = msg.payload.decode()
print(f'Message received: {message}')
broker = '192.168.0.8'
client = mqtt.Client()
client.connect(broker,1883,60)
client.on_connect = on_connect
client.on_message = on_message
client.loop_forever()
有一个蓝牙通信的例子。
我写了一个 Python3 脚本,它在 Raspberry Pi 零 W 上运行,它从 IMU 传感器 (MPU9250) 收集数据并创建 3 个不同的角度值;滚动,俯仰,偏航。看起来像这样:
def main():
while True:
dataAcc = mpu.readAccelerometerMaster()
dataGyro = mpu.readGyroscopeMaster()
dataMag = mpu.readMagnetometerMaster()
[ax, ay, az] = [round(dataAcc[0], 5), round(dataAcc[1], 5), round(dataAcc[2], 5)]
[gx, gy, gz] = [round(dataGyro[0], 5), round(dataGyro[1], 5), round(dataGyro[2], 5)]
[mx, my, mz] = [round(dataMag[0], 5), round(dataMag[1], 5), round(dataMag[2], 5)]
update(gx, gy, gz, ax, ay, az, mx, my, mz)
roll = getRoll()
pitch = getPitch()
yaw = getYaw()
print(f"Roll: {round(roll, 2)}\tPitch: {round(pitch, 2)}\tYaw: {round(yaw, 2)}")
我想做的是将这 3 个值发送到我的 PC 并读取它们。有什么办法可以发送这些数据。
(如果可能,除了 serial
)。
您可以在 pi 上设置一个简单的 Web 服务器,并从同一网络上的任何设备访问该服务器,而无需进行任何花哨的设置。
如果你的 pi zero 有 wifi 或者你可以获得适配器,你可以轻松地使用 flask 或 Django 启动你的服务器。
有很多方法可以做到这一点,仅举几例:
- 从 Raspi 向 PC 发送 UDP 消息
- 从 Raspi 向 PC 发送 TCP 流
- 将读数放入 Redis 并允许您网络上的任何人收集它们 - 例如
- 使用 MQTT 客户端从你的 Raspi 发布读数,并在你作为服务器的 PC 上订阅该主题
- 运行 a Python Multiprocessing Manager 在一台机器上并从另一台机器连接 - 请参阅 “使用远程管理器”。 =49=] here
- 通过蓝牙发送读数
下面是使用 UDP 实现上述第一个建议的可能方法。首先Raspi端产生3个读数X,Y,Z,每秒通过UDP发送给PC:
#!/usr/bin/env python3
import socket
import sys
from time import sleep
import random
from struct import pack
# Create a UDP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
host, port = '192.168.0.8', 65000
server_address = (host, port)
# Generate some random start values
x, y, z = random.random(), random.random(), random.random()
# Send a few messages
for i in range(10):
# Pack three 32-bit floats into message and send
message = pack('3f', x, y, z)
sock.sendto(message, server_address)
sleep(1)
x += 1
y += 1
z += 1
PC端匹配代码如下:
#!/usr/bin/env python3
import socket
import sys
from struct import unpack
# Create a UDP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# Bind the socket to the port
host, port = '0.0.0.0', 65000
server_address = (host, port)
print(f'Starting UDP server on {host} port {port}')
sock.bind(server_address)
while True:
# Wait for message
message, address = sock.recvfrom(4096)
print(f'Received {len(message)} bytes:')
x, y, z = unpack('3f', message)
print(f'X: {x}, Y: {y}, Z: {z}')
这是 MQTT 建议的一种可能实现方式。首先,发布这三个值的发布者。请注意,我的桌面上有 mosquitto
代理 运行ning:
#!/usr/bin/env python3
from time import sleep
import random
import paho.mqtt.client as mqtt
broker = '192.168.0.8'
client = mqtt.Client()
client.connect(broker,1883,60)
# Generate some random start values
x, y, z = random.random(), random.random(), random.random()
# Send a few messages
for i in range(10):
# Publish out three values
client.publish("topic/XYZ", f'{x},{y},{z}');
sleep(1)
x += 1
y += 1
z += 1
这是订阅者,它监听消息并打印它们:
#!/usr/bin/env python3
import socket
import sys
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("topic/XYZ")
def on_message(client, userdata, msg):
message = msg.payload.decode()
print(f'Message received: {message}')
broker = '192.168.0.8'
client = mqtt.Client()
client.connect(broker,1883,60)
client.on_connect = on_connect
client.on_message = on_message
client.loop_forever()
有一个蓝牙通信的例子