У меня есть внешняя таблица mytable
.В Airflow запланировано задание, которое подбирает файл SQL и выполняет его один раз в день.
Ежедневно мне нужно добавить в таблицу раздел, соответствующий этому дню.Поэтому для 2019-09-27 мне нужно будет выполнить
ALTER TABLE MYTABLE ADD PARTITION(year=2018,month=9,day=27,ts=1538006400) location '/path/to/data/20180927/'
. Я могу получить год / месяц / день, используя SELECT year/month/day(current_date)
, а метку времени - select unix_timestamp(CURRENT_DATE, 'yyyy-MM-dd')
, но как мне написать SQLзапрос, который будет генерировать весь ALTER TABLE... ADD PARTITION
запрос, как указано выше?
Сценарии - это простой способ, но мне нужно, чтобы это было сделано только в SQL.