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

相关内容

热门资讯

透视透视!德普辅助软件(透视)... 透视透视!德普辅助软件(透视)免费透视(确实有挂)1)德普辅助软件辅助挂:进一步探索德普辅助软件辅助...
透视ai代打!aapoker怎... 透视ai代打!aapoker怎么提高中牌率(透视)透视脚本下载(好像真的有挂)1、aapoker怎么...
透视挂透视!德普之星辅助器ap... 透视挂透视!德普之星辅助器app(透视)辅助软件(原来存在有挂)1)德普之星辅助器app辅助挂:进一...
透视最新!aapoker俱乐部... 透视最新!aapoker俱乐部靠谱吗(透视)透视脚本下载(本来有挂)1、打开软件启动之后找到中间准星...
透视安卓版!德普之星的辅助工具... 透视安卓版!德普之星的辅助工具介绍(透视)透视辅助软件下载(总是是真的有挂)1、德普之星的辅助工具介...
透视规律!aapoker怎么选... 透视规律!aapoker怎么选牌(透视)真的假的(总是是真的有挂)1)aapoker怎么选牌辅助挂:...
透视了解!德普之星怎么开辅助(... 透视了解!德普之星怎么开辅助(透视)的辅助工具介绍(果然是真的有挂)1、全新机制【德普之星怎么开辅助...
透视数据!aa poker辅助... 透视数据!aa poker辅助(透视)插件下载(总是有挂);1、进入游戏-大厅左侧-新手福利-激活码...
透视免费!德普之星私人局透视(... 透视免费!德普之星私人局透视(透视)透视辅助软件(真是存在有挂)1、每一步都需要思考,不同水平的挑战...
透视游戏!aapoker免费透... 透视游戏!aapoker免费透视脚本(透视)透视方法(好像是有挂)1、任何aapoker免费透视脚本...