загрузить историю данных в таблицу за прошедший год в цикле Python

Всем привет! подскажите, пожалуйста, как лучше решить задачу, мне нужно загрузить историю с 20210101 по 20211231. есть sql скрипт, он подготовлен для запуска раз в полчаса

with toUnixTimestamp(timeSlot(now())) - 1800 as start_tmstmp,
 toUnixTimestamp(timeSlot(now())) as end_tmstmp
select
 dt,
 toUnixTimestamp(toStartOfTenMinutes(fromUnixTimestamp(interval_start_tstmp_))) as interval_start_tstmp,
 visits,
 sum(device_) as device,
 chip_id
from (select intDiv(timestamp, 5) * 5 as interval_start_tstmp_,
 dt,
 visits,
 1 as device_,
 substr(sensor_id,1,9) as chip_id
 from default.advertisment
 where toYYYYMM(dt) = toYYYYMM(now() - interval 30 minute)
 and timestamp >= start_tmstmp
 and timestamp < end_tmstmp
 group by interval_start_tstmp_,
 dt,
 visits,
 substr(sensor_id,1,9)
 )
group by dt,
 interval_start_tstmp,
 visits,
 chip_id

решение через цикл, чтобы перебирались интервалы

через даг - решение у меня есть

благодарю за любую помощь и направление


Ответы (0 шт):