linux 下上传 datapoint数据到yeelink 【golang版本】
package main /* Create by sndnvaps<sndnvaps@gmail.com> * date : 2015-04-05 * upload datapoint to yeelink.net * origin post by sndnvaps * hold on https://github.com/sndnvaps/MyRasPi */ import ( "fmt" "io/ioutil" "net" "time" "os" "strconv" ) func checkError(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s\n",err.Error()) os.Exit(1) } } func GetCpuTemp() (t float32) { tf ,err := os.Open("/sys/class/thermal/thermal_zone0/temp") if err != nil { fmt.Printf("Read Cpu file error = %s\n",err.Error()) } defer tf.Close() data := make([]byte,5) tf.Read(data) data_temp := string(data) temp, _ := strconv.Atoi(data_temp) var tt float32 tt = float32(temp) fmt.Printf("Cpu temp = %2.2f\n", tt/1000.00) return (tt/1000.00) } func main() { //Connet the api.yeelink.net //REMOTE_IP 42.96.164.52 //PORT 80 conn, err := net.Dial("tcp","42.96.164.52:80") defer conn.Close() checkError(err) fmt.Printf("Post Request \n") // fmt.Printf("Cpu temp = %2.2f\n", GetCpuTemp()) time.Sleep(time.Second) _ , err = conn.Write([]byte("POST /v1.0/device/19374/sensor/33945/datapoints HTTP/1.0\r\nHost: api.yeelink.net\r\nAccept: */*\r\n")) //此处要修改为你自己的设备号和传感器 if err != nil { fmt.Printf("Sent Requset ok\n") } /* checkError(err) result, err := ioutil.ReadAll(conn)//get the info checkError(err) fmt.Println(string(result)) */ fmt.Printf("Send the API-keys\n") time.Sleep(time.Second) // send the API-key _ , err = conn.Write([]byte("U-ApiKey: 108968b03a7e9334b2aca7c45b199dee\r\nContent-Length: 15\r\nContent-type: application/json;charset=utf-8\r\n")) //请自行修改为自己的U-ApiKey
checkError(err) time.Sleep(time.Second) //send the '\r\n' _ , err = conn.Write([]byte("\r\n")) checkError(err) //send the value time.Sleep(time.Second) var value string value = fmt.Sprintf("{\"value\":%2.2f}\n\n",GetCpuTemp()) //_ , err = conn.Write([]byte("{\"value\":13.14}\r\n")) // var b []byte //b = str2byte(value) // fmt.Println("b = ", b) _, err = conn.Write([]byte(value)) checkError(err) time.Sleep(time.Second) result, err := ioutil.ReadAll(conn) checkError(err) fmt.Println(string(result)) os.Exit(1) }
可以直接使用go run upload_cpu_temp.go
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。