#python #postgresql #airflow #workflow #prefect
#python #postgresql #поток воздуха #рабочий процесс #префект
Вопрос:
Я использую рабочий процесс префекта для бизнес-приложений.
У меня вопрос о журналах, хранящихся в postgresql.
Если ежедневные журналы хранятся на сервере postgresql, объем данных будет огромным.
Есть ли механизм для поворота этого журнала и записи его в текстовый файл?
Кроме того, можно ли удалять соответствующую запись после записи данных из таблицы postgresql в текстовый файл и т. Д.?
Ответ №1:
Поскольку вы используете экземпляр сервера Prefect, имело бы смысл написать поток, который подключается к контейнеру postgres и архивирует журналы в какое-либо облачное хранилище (GCS, S3 и т. Д.) Для вас. Я бы, наверное, подумал об этом так:
- Используйте префект
Client
для сбора всех идентификаторов прогонов потока старше определенной даты. - Подключитесь к postgres и выберите журналы из таблицы logs для журналов с этими идентификаторами выполнения потока
- Запишите эти журналы в CSV / SQL / Text по своему усмотрению
- Удалите эти журналы из postgres