from_dbms

DBHose.from_dbms(
query: Optional[str] = None,
table: Optional[str] = None,
)
Параметры:

  • query (Optional[str]) – SQL запрос для выборки данных из источника.

  • table (Optional[str]) – Объект таблицы-источника

Полный цикл загрузки данных из СУБД-источника в целевую СУБД. Для работы необходимо указать как минимум один из параметров

Предупреждение

Параметр query имеет приоритет над параметром table, поэтому если указано оба параметра будет выбран параметр query.

Описание:

Выполняет автоматический ETL процесс:

  1. Создает временную таблицу (create_temp)

  2. Загружает данные из источника (write_between)

  3. Проверяет качество данных (dq_check)

  4. Переносит в целевую таблицу (to_table)

Пример:

# Загрузка всей таблицы из источника
dbhose.from_dbms(table="public.source_table")

# Или с фильтрацией
dbhose.from_dbms(
    query="SELECT * FROM events WHERE date >= '2024-01-01'"
)

См. также:

  • create_temp - Создание временной таблицы

  • dq_check - Проверка качества данных

  • to_table - Перенос в целевую таблицу