syunity-meteo

中文 | English

syunity-meteo collects Open-Meteo data selected for China and stores it in Apache IoTDB through syunity-core's pooled IotDBManager.

Install and start

Install dependencies, choose active_mode and update its IoTDB connection values in config.yaml, ensure IoTDB is running, then start the local service:

pip install -e .
python main.py

main.py imports the global settings instance from settings.py; its mode, IoTDB connection values, and standalone collection defaults are loaded from config.yaml. By default, development mode targets 127.0.0.1:6667 and collects Shanghai.

• dev mode: Immediately runs the online interfaces, logs every API response and IoTDB write result, and keeps the scheduler running.

• prod mode: Does not print application-level payloads. It fills historical data once, reads current weather and air quality at minute 00, 15, 30, and 45, and reads weather, radiation, and marine forecasts at 00:00, 06:00, 12:00, and 18:00.

• History: Imported from 2006 one time in a background worker; online scheduling continues while it runs.

• Current weather: Collected at each 15-minute boundary in prod.

• Forecast: Collected at 00:00, 06:00, 12:00, and 18:00 in prod.

When used as a library, MeteoService does not log API results or IoTDB writes by default. Pass log_results=True to opt in:

service = MeteoService(settings, OpenMeteoClient(), store, log_results=True)

IoTDB schema

All data is in the configured database, defaulting to root.meteo. The standalone default city device identifier is shanghai.

Forecast payloads are stored per issue time rather than forecast-valid time. This preserves all four daily forecast versions and avoids overwriting an earlier model run.

Data models

Project layout

main.py                         # Root local startup entry point
config.yaml                     # Editable IoTDB connection configuration
src/syunity_meteo/
  settings.py                   # YAML connection loading and collection schedule
  client.py                     # Open-Meteo API client
  iotdb_store.py                # syunity_core.database.db templates, writes, and queries
  service.py                    # One-time and recurring task scheduling
tests/                          # Standalone readable test functions