Apache Nifi使用多个输入的EvaluateJsonPath
创始人
2024-09-04 13:00:50
0

在Apache Nifi中,您可以使用EvaluateJsonPath处理器来从JSON数据中提取特定字段的值。如果您需要处理多个输入,您可以使用MergeContent处理器将它们合并到一个流中,然后将该流作为EvaluateJsonPath的输入。

以下是一个使用多个输入的EvaluateJsonPath的示例流程:

  1. 在流程中添加一个MergeContent处理器,将多个输入流合并为一个流。配置MergeContent处理器的属性如下:

    • Merge Strategy:使用"Defragment"策略
    • Minimum Number of Entries:设置合并的最小条目数
  2. 在MergeContent处理器后添加一个EvaluateJsonPath处理器。配置EvaluateJsonPath处理器的属性如下:

    • JsonPath Expression:指定要提取的字段的JSON路径表达式
    • Destination:指定提取的字段的属性名
  3. 在EvaluateJsonPath处理器后添加一个LogAttribute处理器,用于将提取的字段值输出到日志中。

以下是一个示例的Groovy脚本,可以使用Apache Nifi的REST API将上述流程导入到Nifi中:

import groovyx.net.http.RESTClient

def baseUrl = 'http://localhost:8080/nifi-api'
def clientId = 'your-client-id'
def processGroupId = 'your-process-group-id'

def restClient = new RESTClient(baseUrl)

// 创建一个新的流程
def createProcessResponse = restClient.post(
    path: '/process-groups/' + processGroupId + '/process-groups',
    headers: [
        'Content-Type': 'application/json',
        'Accept': 'application/json'
    ],
    body: [
        'revision': [
            'clientId': clientId,
            'version': 0
        ],
        'component': [
            'name': 'Multi-input EvaluateJsonPath',
            'position': [
                'x': 0,
                'y': 0
            ]
        ]
    ]
)

def processGroup = createProcessResponse.data
def processGroupId2 = processGroup.id

// 添加MergeContent处理器
def mergeContentProcessor = [
    'revision': [
        'clientId': clientId,
        'version': 0
    ],
    'component': [
        'name': 'MergeContent',
        'type': 'org.apache.nifi.processors.standard.MergeContent',
        'position': [
            'x': 200,
            'y': 200
        ],
        'bundle': [
            'group': 'org.apache.nifi',
            'artifact': 'nifi-standard-nar',
            'version': 'x.y.z'
        ],
        'config': {
            'mergeStrategy': 'Defragment',
            'minimumNumberOfEntries': '2'
        }
    ]
]

def addMergeContentResponse = restClient.post(
    path: '/process-groups/' + processGroupId2 + '/processors',
    headers: [
        'Content-Type': 'application/json',
        'Accept': 'application/json'
    ],
    body: mergeContentProcessor
)

def mergeContentProcessorId = addMergeContentResponse.data.id

// 添加EvaluateJsonPath处理器
def evaluateJsonPathProcessor = [
    'revision': [
        'clientId': clientId,
        'version': 0
    ],
    'component': [
        'name': 'EvaluateJsonPath',
        'type': 'org.apache.nifi.processors.standard.EvaluateJsonPath',
        'position': [
            'x': 400,
            'y': 200
        ],
        'bundle': [
            'group': 'org.apache.nifi',
            'artifact': 'nifi-standard-nar',
            'version': 'x.y.z'
        ],
        'config': {
            'jsonPathExpression': '$.field',
            'destination': 'field'
        }
    ]
]

def addEvaluateJsonPathResponse = restClient.post(
    path: '/process-groups/' + processGroupId2 + '/processors',
    headers: [
        'Content-Type': 'application/json',
        'Accept': 'application/json'
    ],
    body: evaluateJsonPathProcessor
)

def evaluateJsonPathProcessorId = addEvaluateJsonPathResponse.data.id

// 添加LogAttribute处理器
def logAttributeProcessor = [
    'revision': [
        'clientId': clientId,
        'version': 0
    ],
    'component': [
        'name': 'LogAttribute',
        'type': 'org.apache.nifi.processors.attributes.LogAttribute',
        'position': [
            'x': 600,
            'y': 200
        ],
        'bundle': [
            'group': 'org.apache

相关内容

热门资讯

透视真的!aapoker破解侠... 透视真的!aapoker破解侠是真的吗(透视)辅助插件工具(确实有挂);1、进入游戏-大厅左侧-新手...
透视ai!aapoker脚本(... 透视ai!aapoker脚本(透视)透视插件(果然存在有挂)1、任何aapoker脚本ai辅助神器的...
透视苹果版!aapoker辅助... 透视苹果版!aapoker辅助插件工具(透视)透视软件(本来存在有挂);亲,关键说明,aapoker...
透视数据!aapoker公共底... 透视数据!aapoker公共底牌(透视)透视软件(本来是有挂)1、完成aapoker公共底牌透视辅助...
透视ai!aapoker俱乐部... 透视ai!aapoker俱乐部靠谱吗(透视)辅助插件工具(真是真的有挂)1、这是跨平台的aapoke...
透视讲解!aapoker怎么控... 透视讲解!aapoker怎么控制牌(透视)透视脚本(一贯是真的有挂);1、透视讲解!aapoker怎...
辅助透视!aapoker免费透... 辅助透视!aapoker免费透视脚本(透视)透视脚本(总是存在有挂)1、每一步都需要思考,不同水平的...
透视免费!aapoker插件(... 透视免费!aapoker插件(透视)插件(果然是有挂)1、在aapoker插件ai机器人技巧中,中转...
透视插件!aapoker怎么选... 透视插件!aapoker怎么选牌(透视)免费透视脚本(总是是有挂);1、aapoker怎么选牌ai辅...
透视ai代打!aapoker能... 透视ai代打!aapoker能控制牌吗(透视)透视方法(本来存在有挂);1、下载好aapoker能控...