My goals is to add some sensors via MQTT to my stations which are all RPi 3
and use WeeWx 3.8.0. I am running the Mosquitto broker on the same RPi as
WeeWx
One station uses a Ultimeter 2100 driver -* can I use WeeWxMQTT as a
service*?
Other stations are a combination of OWFS and FileParse (using a python
program to read from i2c bus on RPi).
The station I am testing/developing (driving myself crazy) on now has
WeeWxMQTT set as driver and OWFS as a service. It gives me errors like:
Apr 6 09:22:44 ru-pi weewx[17871]: wxMesh: Working on queue of 0
Apr 6 09:22:44 ru-pi weewx[17871]: wxMesh: Sleeping for 5
This tells me that WeeWxMqTT is not finding the MQTT messages in the
correct format.
I am struggling with getting the esp8266 to output anything resembling the
expected:
TIME:0,AMBT: 7.23,BARP:1001.97,RHUM:70.92,HUMT:
4.44,IRRA:12,BATV:974,PHOV:673,SYST:33.20,WIND: 0.0,WDIR: 0.0 (from the
WeeWxMQTT
wiki)
The output is have managed to send is like this:
* {"temperature":69.12} *
*My Arduino sketch for the esp8266 is:*
// use OWFS temperature sensor
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <OneWire.h>
#include <DallasTemperature.h>
// Data wire is plugged into pin 2 on the Arduino
#define ONE_WIRE_BUS 5
// Setup a oneWire instance to communicate with any OneWire devices
// (not just Maxim/Dallas temperature ICs)
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);
// Update these with values suitable for your network.
const char* ssid = "My Network";
const char* password = "MyPW";
const char* mqtt_server = "10.0.0.161";
char* topic ="weather";
WiFiClient espClient;
PubSubClient client(espClient);
long lastMsg = 0;
float temp = 0;
int inPin = 5;
String dataString;
char charBuf[150];
void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED)
{
delay(500);
Serial.print(".");
}
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
void reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
// Attempt to connect
if (client.connect("arduinoClient_temperature_sensor")) {
Serial.println("connected");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
}
void setup()
{
Serial.begin(115200);
setup_wifi();
client.setServer(mqtt_server, 1883);
pinMode(inPin, INPUT);
sensors.begin();
}
void loop()
{
if (!client.connected()) {
reconnect();
}
client.loop();
long now = millis();
if (now - lastMsg > 5000) {
lastMsg = now;
sensors.setResolution(12);
sensors.requestTemperatures(); // Send the command to get temperatures
temp = sensors.getTempCByIndex(0);
Serial.println(temp);
temp = (temp *1.8) + 32; // convert to F
Serial.println(temp);
if((temp > -20) && (temp <110))
dataString = String("{\"temperature\":") + temp + String("}");
dataString.toCharArray(charBuf, 150);
{
client.publish(topic,charBuf );
}
}
}
*Any advice would be greatly appreciated. *
--
You received this message because you are subscribed to the Google Groups
"weewx-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to weewx-user+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
