Использование сопоставления потоков данных внутри каждого действия конвейера фабрики данных azure

Question

Сценарий : У меня есть SQL DB CD C net изменений, поступающих в файл csv. В конвейере для каждой строки в файле csv необходимо проверить наличие обновлений, вставок и удалений, а также внести некоторые изменения в мою базу данных хранилища.

конвейер :

поток данных сопоставления:

Проблема :

Как использовать item () из foreach в потоке данных и извлечь эту запись из файла csv и обработать. Я не вижу ни одного поля / параметра на исходном этапе потока данных.

Answer 1

Здесь нет необходимости использовать ForEach. Поток данных может считывать каждую строку из исходного файла CD C, и вы можете применить соответствующую операцию вставки, обновления, слияния, удаления в качестве политик в преобразовании Alter Row.

Answer 2

Во-первых, вы можете добавить параметр в поток данных:

Затем вне потока данных щелкните поток данных, установите данные параметр потока с выражением конвейера:

Затем вы можете установить Foreach item() в качестве параметра потока данных:

Теперь вы можете использовать item () из foreach в потоке данных и получать эту запись из файла csv и обрабатывать.

Надеюсь, это поможет.