Hector GODZIEN
03/12/2024, 2:57 PMimport httpx
from prefect import flow
@flow
def fetch_windspeed(lat: float = 39.8, lon: float = -77):
base_url = "<https://api.open-meteo.com/v1/forecast>"
speeds = httpx.get(
base_url,
params=dict(latitude=lat, longitude=lon, hourly="wind_speed_10m" )
)
print("Forecast windspeed:", speeds.json().get('hourly').get('wind_speed_10m')[0])
return speeds.json().get('hourly').get('wind_speed_10m')[0]
if __name__ == "__main__":
fetch_windspeed.serve(name="lab-101", cron="* * * * *")