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有什么规律吗,aapoker能玩原来是有挂(详细有猫腻教程)辅助器中分为三种...
透视辅助!红龙扑克竟然是真的有... 透视辅助!红龙扑克竟然是真的有挂,红龙扑克果然是真的有挂(详细辅助工具教程);无聊就玩这款真的有辅助...
透视辅助!微扑克网页版辅助,(... 透视辅助!微扑克网页版辅助,(微扑克总结)其实有挂(详细wpk透视辅助教程)1)wpk透视辅助辅助挂...
一分钟了解!!红龙poker正... 一分钟了解!!红龙poker正规吗,红龙扑克真是存在有挂(详细辅助器教程);小薇(透视辅助)致您一封...
5分钟了解!微扑克透视辅助脚本... 5分钟了解!微扑克透视辅助脚本,微扑克规律一直真的是有挂(详细wpk透视辅助教程)所有人都在同一条线...
透视辅助!aaPOKER原来是... 透视辅助!aaPOKER原来是真的有挂,aapoker辅助确实存在有挂(详细外卦挂教程);1、实时a...
透视辅助!微扑克ai辅助器苹果... 透视辅助!微扑克ai辅助器苹果版,(微扑克代码)本来是真的有挂(详细ai辅助器苹果版教程)是一款可以...
盘点一款!!德扑计算胜率软件,... 盘点一款!!德扑计算胜率软件,德扑之星模拟器竟然是真的有挂(详细线上房间教程);一、AI软件牌型概率...
透视辅助!wPK透视辅助软件,... 透视辅助!wPK透视辅助软件,WPK线上其实真的是有挂(详细透明挂教程)1、打开软件启动之后找到中间...
透视辅助!wPk果然有挂,wp... 透视辅助!wPk果然有挂,wpk机制好像存在有挂(详细透明挂教程)1、进入游戏-大厅左侧-新手福利-...