weather2

DROP TABLE IF EXISTS kdz17.staging_weather_facts;
CREATE TABLE IF NOT EXISTS kdz17.staging_weather_facts (
   icao_code varchar(10) NOT NULL,
   local_datetime timestamp NOT NULL,  -- Изменен тип на timestamp
   t_air_temperature numeric(3, 1),
   p0_sea_lvl numeric(4, 1),
   p_station_lvl numeric(4, 1),
   u_humidity int,
   dd_wind_direction varchar(100),
   ff_wind_speed int,
   ff10_max_gust_value int,
   ww_present varchar(100),
   ww_recent varchar(50),
   c_total_clouds varchar(200),
   vv_horizontal_visibility numeric(3, 1),
   td_temperature_dewpoint numeric(3, 1),
   loaded_ts timestamp NOT NULL DEFAULT now(),
   PRIMARY KEY (icao_code, local_datetime)
);