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

【问题标题】：How to transform a JSON data directly in a Azure Data Factory pipeline如何在 Azure 数据工厂管道中直接转换 JSON 数据
【发布时间】：2020-10-20 14:46:09
【问题描述】：

我在连接到数据流的 Azure 数据工厂管道中进行了查找。查找以以下形式返回 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。

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

有没有办法在我的管道中实现这种转换？

【问题讨论】：

查找活动的 JSON 数组中的键是否相同？
你的意思是对象键吗？它始终是 COLUMN_NAME

标签： azure azure-data-factory-2 azure-data-factory-pipeline

【解决方案1】：

你可以添加一个变量，类型是数组，然后使用 For Each 活动并附加变量活动。

步骤：

1.创建一个名为 string_array 的变量

2.创建一个For Each活动，表达式：@activity('GetKeyColumns').output.value

3.在每个活动中创建一个附加变量活动，表达式：@item()['COLUMN_NAME']

4.使用管道表达式将字符串数组传递给数据流：@variables('string_array')

【讨论】：