Добавочная загрузка с использованием АПД с отслеживанием изменений
Я построил конвейер в ADF, который постепенно загружает данные с сервера SQL в базу данных SQL Azure с помощью механизма отслеживания изменений. Вот ссылка, по которой я следил:https://www.sqlservercentral.com/articles/incremental-data-loading-through-adf-using-change-tracking Как мне изменить исходный запрос в активности копирования данных для несколько таблиц. Ниже приводится запрос, который я использую.
SELECT
s.*,
c.SYS_CHANGE_VERSION,
c.SYS_CHANGE_OPERATION,
c.SYS_CHANGE_COLUMNS
FROM @{item().TABLE_SCHEMA}.@{item().TABLE_NAME} AS s
RIGHT OUTER JOIN CHANGETABLE(
CHANGES @{item().TABLE_SCHEMA}.@{item().TABLE_NAME},
@{activity('lkupLastChngTrackVer').output.firstRow.SYS_CHANGE_VERSION}) as c
ON s.[studentId] = c.[studentId]
where c.SYS_CHANGE_VERSION <=
@{activity('lkupCurChngTrackVer').output.firstRow.CurrentChangeTrackingVersion}
Этот запрос не работает в случае удаления. Также данные второй таблицы загружаются дважды, когда я запускаю конвейер. Благодарю за помощь
Спасибо Gauri pawse