example.py

# pip install wetterdienst==0.9.0 crate[sqlalchemy]
# pip install cr8
#
# Usage:
#   cr8 run-crate 4.2.x
#   python example.py

from sqlalchemy import create_engine
from wetterdienst import DWDObservationData
from wetterdienst import Parameter, PeriodType, TimeResolution


if __name__ == "__main__":
    engine = create_engine("crate://localhost:4200")
    observations = DWDObservationData(
        station_ids=[1048],
        parameter=[Parameter.TEMPERATURE_AIR],
        time_resolution=TimeResolution.HOURLY,
        start_date="2019-01-01",
        end_date="2020-01-01",
        tidy_data=True,
        humanize_column_names=True,
    )
    df = observations.collect_safe().dwd.lower()
    df.to_sql("weather", engine, "doc", if_exists="append", index=False)