NodeMCU发送数据给树莓派

>>> from machine import Pin
>>> led = Pin(0, Pin.OUT)
>>> led.on()
>>> led.off()

>>> import network
>>> wlan.connect("djhxiaomi", "0987654321")
>>> wlan.isconnected()
True

>>> import dht
>>> dh = dht.DHT11(machine.Pin(4))
>>> dh.measure()
>>> dh.temperature()
30
>>> dh.humidity()
56

>>> import urequests
>>> response = urequests.get("http://api.com/test")
>>> print(response.text)

>>> import urequests
>>> import json
>>> api_url = "http://api.com/test"
>>> sensor_data = {"name" : "koril", "status" : 100}
>>> headers = {"Content-type" : "application/json"}
>>> response = urequests.post(api_url, data = json.dumps(sensor_data), headers = headers)
>>> print(response.text)

import time
from machine import Pin

led = Pin(0, Pin.OUT)
def blink():
    while True:
        led.on()
        time.sleep(1)
        led.off()
        time.sleep(1)
blink()

import network
import urequests
import time
import machine
import dht
import json

dh = dht.DHT11(machine.Pin(4))

# 树莓派上的服务端口
api_url = "http://korilweb.cn:8090/data"

# 因为有时候带到不同的地方，学校，家里，还有公司
# 所以用一个 dict 存放所有的 WiFi 信息
wifi_dict = {
    "home" : ["TP-LINK_832B", "sqf1226lhw"],
    "phone" : ["djhxiaomi", "0987654321"]
}

# 对某个WiFi进行连接
def do_connect(SSID, PASSWORD):
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    if not wlan.isconnected():
        print("connecting to " + SSID)
        wlan.connect(SSID, PASSWORD)
        
    start = time.time()
    while not wlan.isconnected():
        time.sleep(1)
        # 超过5秒，认为连接超时
        if time.time() - start > 5:
            print("connect timeout!")
            break
    # 连接成功，返回 True，打印 wlan 信息
    if wlan.isconnected():
        print('network config:', wlan.ifconfig())
        return True
    # 连接失败，返回 False
    return False

# 对 WiFi 字典进行遍历，某一个连接成功，就发送数据
def connect_wifi(wifi_dict):
    for wifi_info in wifi_dict:
        is_connected = do_connect(wifi_dict[wifi_info][0], wifi_dict[wifi_info][1])
        if is_connected:
            time.sleep(1)
            while True:
                send_data()
                time.sleep(1)
    print("no wifi")

# 发送传感器数据
def send_data():
    tempAndHumidity = getTempAndHumidity()
    sensor_data = {
        "temperature" : tempAndHumidity[0],
        "humidity" : tempAndHumidity[1]
    }
    headers = {
        "Content-Type" : "application/json"
    }

    response = urequests.post(
        api_url,
        data = json.dumps(sensor_data), 
        headers = headers
    )
    print(response.text)

# 获取 DHT11 的数据，温度和湿度，以元组的形式返回
def getTempAndHumidity():
    dh.measure()
    return (dh.temperature(), dh.humidity())


connect_wifi(wifi_dict)

package com.example.raspberry.controller;

import com.example.raspberry.entity.Sensor;
import org.springframework.web.bind.annotation.*;

@RestController
public class HelloController {

    @PostMapping(value = "/data")
    public String data(@RequestBody Sensor sensor) {
        System.out.println("temp: " + sensor.getTemperature());
        System.out.println("humidity: " + sensor.getHumidity());
        return "get data";
    }
}

package com.example.raspberry.entity;

public class Sensor {

    // 温度
    private Integer temperature;
    // 湿度
    private Integer humidity;

    public Integer getTemperature() {
        return temperature;
    }

    public void setTemperature(Integer temperature) {
        this.temperature = temperature;
    }

    public Integer getHumidity() {
        return humidity;
    }

    public void setHumidity(Integer humidity) {
        this.humidity = humidity;
    }

    @Override
    public String toString() {
        return "Sensor{" +
                "temperature=" + temperature +
                ", humidity=" + humidity +
                '}';
    }
}