NIFI:无法从JSON提取值

Question

最初，我正在查询一个表格以获取两个值ID，有效负载。有效负载字段再次是JSON，但在字符串中。请检查下面的有效载荷字符串。

{
  "schema": "http://schemas.viacom.com/what/is/the/path#",
  "op": "delete",
  "entity": "movie",
  "entity_identifier": {
    "series_code": 53709,
    "episode_code": 1
  },
  "entity_vmid": "",
  "short_name": "",
  "title": ""
}

我想要series_code和Episody_code值。我尝试以下方式，但无用

1. executesql-> convertavrotojson-> evaluewuatejson（$。payload.entity_identifier.series_code）
2. executesql-> convertavrotojson-> attributeStojson-> estaruejson

请帮忙。

Answer 1

您可以使用EvaluateJsonPath处理器来评估JSONPATH表达式针对流汇的内容。您要提取的每个值添加一个用户定义的属性。将Destination值设置为flowfile-attribute，以将值提取到属性中，该属性将添加到FlowFile，或flowfile-content以生成带有提取值作为唯一内容的新FlowFile。

给定您提供的JSON，您要使用的两个路径表达式是：

• $.entity_identifier.series_code-> 53709
• $.entity_identifier.episode_code-> 1