github.com/tris/weatherflow

weatherflow

weatherflow is a Go module for streaming rapid observations from the WeatherFlow Tempest API.

Installation

go get -u github.com/tris/weatherflow

Example

import (
	"fmt"
	"log"
	"github.com/tris/weatherflow"
)

func main() {
	client := weatherflow.NewClient("your-token-here", nil, log.Printf)

	client.AddDevice(12345)

	client.Start(func(msg weatherflow.Message) {
		switch m := msg.(type) {
		case *weatherflow.MessageObsSt:
			fmt.Printf("Observation: %+v\n", m)
		case *weatherflow.MessageRapidWind:
			fmt.Printf("Rapid wind: %+v\n", m)
		}
	})

	time.Sleep(30 * time.Second)

	client.Stop()
}

Limitations

• Only Tempest and Rapid Wind observations are passed:
  • Acknowledgement (ack)
  • Rain Start Event (evt_precip)
  • Lightning Strike Event (evt_strike)
  • Device Online Event (evt_device_online)
  • Device Offline Event (evt_device_offline)
  • Station Online Event (evt_station_online)
  • Station Offline Event (evt_station_online)
  • Rapid Wind (3 sec) (rapid_wind)
  • Observation (Air) (obs_air)
  • Observation (Sky) (obs_sky)
  • Observation (Tempest) (obs_st)

TODO

• Track delayed observations (occasionally the API will emit several obs_st in a batch which are up to 10 minutes old)
• Track missing observations
• Track duplicate observations (occasionally the API will emit up to four rapid observations for the same timestamp)

Credit

I took a bit of inspiration from the excellent goweatherflow module, which you should use instead if your Tempest is on the same LAN.