Generating messages to an IoT data pipeline
Before we write any code, let’s take a look at the schema of the metrics data we’ll be sending to the broker.
Examining the simulated metrics data
Our data is based on consumer metrics generated by a smart thermostat. While it isn’t the raw data directly transmitted by the device to the thermostat company’s servers, it can be considered representative of the kind of data typical of such a device. This is the list of fields from the header of data/thermostat_events.csv:
System Setting,System Mode,Calendar Event,Program Mode,Cool Set Temp (F),Heat Set Temp (F),Current Temp (F),Current Humidity (%RH),Outdoor Temp (F),Wind Speed (km/h),Cool Stage 1 (sec),Heat Stage 1 (sec),Aux Heat 1 (sec),Fan (sec),DM Offset,Thermostat Temperature (F),Thermostat Humidity (%RH),Thermostat Motion,Upstairs (F),Upstairs2
Most of the fields we’re interested in are temperatures, denoted by (F). We’ll also add the...
