Поделиться через


Преобразование flowlet в потоке данных для сопоставления

ОБЛАСТЬ ПРИМЕНЕНИЯ: Фабрика данных Azure Azure Synapse Analytics

Совет

Попробуйте использовать фабрику данных в Microsoft Fabric, решение для аналитики с одним интерфейсом для предприятий. Microsoft Fabric охватывает все, от перемещения данных до обработки и анализа данных в режиме реального времени, бизнес-аналитики и отчетности. Узнайте, как бесплатно запустить новую пробную версию !

Потоки данных доступны в конвейерах как Фабрики данных Azure, так и Azure Synapse. Эта статья относится к потокам данных для сопоставления. Если вы не знакомы с преобразованиями, см. вводную статью Преобразование данных с помощью потока данных для сопоставления.

Используйте преобразование flowlet для запуска ранее созданного потока потока данных сопоставления. Общие сведения о потоках flowlet см. Потоки flowlet в потоке данных для сопоставления | Документация Майкрософт

Примечание.

Преобразование flowlet в конвейерах Фабрики данных Azure и Synapse Analytics в настоящее время находится на этапе общедоступной предварительной версии.

Настройка

Преобразование flowlet поддерживает следующие параметры конфигурации:

Снимок экрана: конфигурация параметров flowlet.

Поток

Выберите поток flowlet для запуска. После выбора потока flowlet вы сможете сопоставлять входные столбцы (если они есть) на вкладке "Сопоставление".

Сопоставление

Снимок экрана: сопоставление столбцов с входным потоком.

Если выбранный поток flowlet содержит входные столбцы, можно сопоставлять столбцы из входного потока с ожидаемыми входными столбцами в потоке flowlet. Это сопоставление столбцов потоков данных для сопоставления с потоком flowlet позволяет использовать потоки flowlet в качестве повторно используемых фрагментов кода логики потоков данных для сопоставления в потенциально большом количестве потоков данных для сопоставления.

Скрипт потока данных

Синтаксис

<incomingStream>
<transformation> ~> <transformationName>
<outputStream>

Пример

source1 derive(Test = "test") ~> DerivedColumn1
DerivedColumn1 output() ~> output1