linux 下上传 datapoint数据到yeelink 【golang版本】

package main

/* Create by sndnvaps<[email protected]>
 * 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 

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。