Поток данных используется для извлечения, преобразования и загрузки данных из источника в целевую систему. Все преобразования, загрузка и форматирование происходит в потоке данных.
После определения потока данных в проекте его можно добавить в рабочий процесс или задание ETL. Поток данных может отправлять или получать объекты / информацию, используя параметры. Поток данных назван в формате DF_Name .
Пример потока данных
Предположим, что вы хотите загрузить таблицу фактов в систему DW с данными из двух таблиц в исходной системе.
Поток данных содержит следующие объекты —
- Таблица с двумя источниками
- Соединение между двумя таблицами и определено в преобразовании запроса
- Целевой стол
Существует три типа объектов, которые можно добавить в поток данных. Они —
- Источник
- цель
- Трансформации
Шаг 1 — Перейдите в Локальную библиотеку объектов и перетащите обе таблицы в рабочее пространство.
Шаг 2. Чтобы добавить преобразование запроса, перетащите курсор с правой панели инструментов.
Шаг 3 — Соедините обе таблицы и создайте целевую таблицу шаблонов, щелкнув правой кнопкой мыши поле Запрос → Добавить новый → Новая таблица шаблонов.
Шаг 4 — Введите имя целевой таблицы, имя хранилища данных и владельца (имя схемы), под которым должна быть создана таблица.
Шаг 5 — Перетащите целевой стол вперед и присоедините его к преобразованию запроса.
Передача параметров
Вы также можете передавать различные параметры в и из потока данных. При передаче параметра в поток данных объекты в потоке данных ссылаются на эти параметры. Используя параметры, вы можете передавать различные операции потоку данных.
Пример. Предположим, вы ввели параметр в таблицу с последним обновлением. Позволяет извлечь только те строки, которые были изменены с момента последнего обновления.