要通过比较多行具有不同数据的方式创建新列，可以使用Apache NiFi中的EvaluateJsonPath处理器和ExecuteScript处理器。下面是一个使用Python脚本的解决方法示例：

1. 配置EvaluateJsonPath处理器：

   • 将EvaluateJsonPath处理器添加到NiFi流程中。
   • 配置JsonPath表达式来提取需要比较的数据字段，并使用属性名称存储提取的值。例如，可以使用$.data.field1和$.data.field2分别提取两个字段的值。
   • 将提取的值存储在属性中，以便在后续步骤中使用。

2. 配置ExecuteScript处理器：

   • 将ExecuteScript处理器添加到NiFi流程中，并将其连接到EvaluateJsonPath处理器。
   • 配置Script Engine为Python。
   • 编写以下Python脚本来进行比较并创建新列：

import json

flowFile = session.get()
if flowFile is not None:
    try:
        # 获取EvaluateJsonPath处理器中提取的属性值
        field1 = flowFile.getAttribute('field1')
        field2 = flowFile.getAttribute('field2')
        
        # 比较字段值并创建新列
        if field1 == field2:
            new_column = 'same'
        else:
            new_column = 'different'
        
        # 将新列添加到JSON数据中
        json_data = json.loads(flowFile.getAttribute('json'))
        json_data['new_column'] = new_column
        
        # 将更新后的JSON数据写回流文件
        flowFile = session.putAttribute(flowFile, 'json', json.dumps(json_data))
        
        session.transfer(flowFile, REL_SUCCESS)
    except Exception as e:
        # 处理异常情况
        log.error(str(e))
        session.transfer(flowFile, REL_FAILURE)

3. 配置连接：
   • 将ExecuteScript处理器连接到下一个处理器（例如PutFile）以便将结果写入文件或其他目标。
   • 配置连接的成功和失败关系。

这样，当流文件通过流程时，EvaluateJsonPath处理器将提取的字段值存储在属性中，然后ExecuteScript处理器将使用Python脚本进行比较并创建新列，并将更新后的JSON数据写回流文件。最后，流文件将传输到下一个处理器进行进一步处理或写入目标。