如何直接在 Azure 数据工厂管道中转换 JSON 数据

Question

我在连接到数据流的 Azure 数据工厂管道中进行了查找。查找 returns 一个 JSON 形式的数组：

[
    {
        "COLUMN_NAME": "country_code"
    },
    {
        "COLUMN_NAME": "customer_role"
    },
    {
        "COLUMN_NAME": "valid_from"
    },
    {
        "COLUMN_NAME": "valid_to"
    }
]

数据流接受一个字符串数组作为参数。因此，我需要一种方法将数据从查找转换为以下形式的字符串数组：

[
    "country_code",
    "customer_role",
    "valid_from",
    "valid_to"
]

在我的管道中，查找的输出可用作管道表达式：@activity('GetKeyColumns').output.value。

对于数据流，我可以选择是使用数据流表达式还是管道表达式来传递参数（字符串数组）。数据流表达式有一个映射函数，可以映射数据结构。但是我不知道如何在此函数中使用查找的输出。

有什么方法可以在我的管道中实现这种转换？

Answer 1

你可以添加一个变量，类型是数组，然后使用 For Each activity 并追加变量 activity.

步骤：

1.create 一个名为 string_array 的变量

2.create a For Each activity,表达式:@activity('GetKeyColumns').output.value

3.create一个Append variable activity inside For each avtivity,expression:@item()['COLUMN_NAME']

4.pass string_array使用管道表达式进行数据流转：@variables('string_array')

如何直接在 Azure 数据工厂管道中转换 JSON 数据

How to transform a JSON data directly in a Azure Data Factory pipeline

azure

azure-data-factory-2

azure-data-factory-pipeline