OpenWeather Winddaten in loop / Belchertown Skin

[teffi71]

Ich hatte gehofft, dass ich mit den Daten von OpenWeather Windwerte in Belchertown anzeigen könnte, da meine mobile Wetterstation keinen Windmesser hat.

In Deinem OpenWeather-Wiki schreibst Du,

I see no use in putting downloaded data into LOOP packets here, as their data is updated at most once per 5 minutes.

Falls die Windwerte aber im loop wären, könnte ich sie doch unter

[StdCalibrate]
    [[Corrections]]
        # For each type, an arbitrary calibration expression can be given.
        # It should be in the units defined in the StdConvert section.
        # Example:
        foo = foo + 0.2
        windSpeed = RVWindSpeed
        windDir = RVWindDir
        windGust = RVWindGust`

einbinden und dann müssten sie doch in der Skin Belchertown auftauchen, oder?

Müsstest Du da etwas ändern oder kann ich das auch selbst hinbekommen?

[roe-dl]

Die Daten bei OpenWeather werden nicht so häufig berechnet, daß es sich lohnen würde, sie in die LOOP-Pakete einzufügen. Deshalb werden sie nur in den ARCHIVE-Datensatz eingefügt. Für die Darstellung in der Belchertown-Skin müßte man die Werte mit $current in die Vorlage index.html.tmpl einbauen und in belchertown.js das Setzen der Werte auskommentieren. Alternativ dazu könnte man in der Vorlage auch die Klassen rausnehmen. Dann werden sie auch nicht mehr aktualisiert.

[teffi71]

Die Werte $current.RVWindSpeed, etc. werden in der Belchertown Skin richtig dargestellt. Neben WindSpeed ist auch WindDir und WindGust im Screenshot zu sehen. Das klappt ...

[teffi71]

Da ich aber dennoch 😄 die Winddaten in der LOOP haben möchte, habe ich mit blackbox.ai diesen Code generieren lassen:

import sys
sys.path.insert(0, '/usr/share/weewx')

import sqlite3
import weewx
import weewx.engine
import logging
import weewx
from weewx.configobj import WeewxConfig
from weewx.engine import StdEngine
from weewx.manager import get_manager_dict

# Load the WeeWX configuration file
config_path = '/etc/weewx/weewx.conf'  # adjust the path to your WeeWX configuration file
config = WeewxConfig(config_path)

# Create a manager dictionary from the configuration
bindings_dict = config.bindings
databases_dict = config.databases
data_binding = config.data_binding
config_dict = weewx.manager.get_manager_dict(bindings_dict, databases_dict, data_binding)



# Define the database connection parameters
DB_PATH = '/var/lib/weewx/weatherservices-readings-OpenWeather.sdb'

# Define the SQL query to retrieve the latest wind data
SQL_QUERY = """
    SELECT RVWindSpeed, RVWindDir, RVWindGust
    FROM archive
    ORDER BY dateTime DESC
    LIMIT 1
"""

# Set up logging
logging.basicConfig(filename='/var/log/weewx/wind_updater.log', level=logging.INFO)

def get_latest_wind_data():
    try:
        # Connect to the database
        conn = sqlite3.connect(DB_PATH)
        cursor = conn.cursor()

        # Execute the SQL query
        cursor.execute(SQL_QUERY)

        # Fetch the result
        result = cursor.fetchone()

        # Print the result for debugging
        print("Retrieved wind data:", result)

        # Close the database connection
        conn.close()

        # Return the wind data as a tuple (windSpeed, windDir, windGust)
        return result
    except sqlite3.Error as e:
        logging.error(f"Error retrieving wind data: {e}")
        return None

def update_current_wind_values(wind_data):
    if wind_data is None:
        logging.error("No wind data available")
        return

    try:
        # Create an instance of the StdEngine class
        engine = weewx.engine.StdEngine(weewx.config.WeewxConfig(config_dict))

        # Create a new loop packet with the updated wind data
        packet = weewx.engine.StdLoopPacket()
        packet['windSpeed'] = wind_data[0]
        packet['windDir'] = wind_data[1]
        packet['windGust'] = wind_data[2]

        # Update the current weather data
        engine.new_loop_packet(packet)
    except Exception as e:
        logging.error(f"Error updating wind values: {e}")

def main():
    # Get the latest wind data from the database
    wind_data = get_latest_wind_data()

    # Update the current wind values
    update_current_wind_values(wind_data)

if __name__ == '__main__':
    main()

Wenn ich den Code laufen lasse bekomme ich aber einen Fehler:

Traceback (most recent call last):
  File "/etc/weewx/bin/user/user_wind_updater.py", line 9, in <module>
    from weewx.configobj import WeewxConfig
ModuleNotFoundError: No module named 'weewx.configobj'

Was mache ich falsch bzw. blackbox.ai?

[roe-dl]

Ich verstehe das Programm nicht so richtig, aber weewx.configobj gibt es wirklich nicht. Es gibt configobj allein. Das wiederum hat aber nur eine Klasse ConfigObj.

[teffi71]

Danke für das Feedback!

Ich habe jetzt einen anderen Weg eingeschlagen ...

[teffi71]

So, ich habe blackbox.ai gebeten, die Werte aus der db per MQTT zu veröffentlichen. Und das klappt 😄

Hier ist der Code:

Import the necessary libraries
import sqlite3
import subprocess
import json

# Define the database file and the MQTT broker
db_file = '/var/lib/weewx/weatherservices-readings-OpenWeather.sdb'
mqtt_broker = 'Broker_url'
mqtt_topic = 'RVGPS/loop'
mqtt_username = 'username'
mqtt_password = 'password'

# Connect to the database
try:
    conn = sqlite3.connect(db_file)
    cursor = conn.cursor()
    print("Connected to the database successfully.")
except sqlite3.Error as e:
    print(f"Failed to connect to the database: {e}")
    exit(1)

# Query the database for the latest wind data
try:
    # Assuming the timestamp column is named 'dateTime'
    cursor.execute("SELECT RVWindSpeed, RVWindDir, RVWindGust FROM archive ORDER BY dateTime DESC LIMIT 1")
    print("Query executed successfully.")
except sqlite3.Error as e:
    print(f"Failed to execute query: {e}")
    conn.close()
    exit(1)

# Fetch the latest row from the query
row = cursor.fetchone()
print(f"Fetched {row} from the database.")

# Close the database connection
conn.close()
print("Database connection closed.")

# Publish the wind data to the MQTT topic using mosquitto_pub
if row:
    # Assuming the wind data is in the first three columns
    wind_speed, wind_dir, wind_gust = row
    try:
        # Construct the payload
        payload = f"{{\"windSpeed\": \"{wind_speed}\", \"windDir\": \"{wind_dir}\", \"windGust\": \"{wind_gust}\"}}"
        # Construct the mosquitto_pub command
        command = f"mosquitto_pub -u {mqtt_username} -P {mqtt_password} -h {mqtt_broker} -t {mqtt_topic} -m '{payload}'"
        # Execute the command with a timeout of 10 seconds
        subprocess.run(command, shell=True, check=True, timeout=30)
        print(f"Published wind data to topic {mqtt_topic}.")
    except subprocess.TimeoutExpired:
        print("Timeout expired while publishing wind data.")
    except subprocess.CalledProcessError as e:
        print(f"Failed to publish wind data: {e}")
else:
    print("No data found in the database.")

Das Python script werde ich dann alle 5 - 10 ausführen lassen ...