时间戳

首页 > 解决方案 > spring integration spel 表达式从消息有效负载中提取字段

java - spring integration spel 表达式从消息有效负载中提取字段

问题描述

对于消息有效负载，我无法理解 SPEL。我想从我的消息有效负载的某些字段中提取数据，这些字段本质上是将以下 JSON 转换为Map<String, Object>并传递给@Transformer

{
  "expand":"renderedFields,names,schema,transitions,operations,editmeta,changelog,versionedRepresentations",
  "id":"14730",
  "self":"https://jira.foo.com/rest/api/2/issue/14730",
  "key":"SDP-145",
  "fields":{
    "issuetype":{
      "self":"https://jira.foo.com/rest/api/2/issuetype/10200",
      "id":"10200",
      "description":"gh.issue.epic.desc",
      "iconUrl":"https://jira.foo.com/ghanghor/viewkaka?size=xsmall&kakaId=10501&kakaType=issuetype",
      "name":"Epic",
      "subtask":false,
      "kakaId":10501
    },
    "priority":{
      "self":"https://jira.foo.com/rest/api/2/priority/3",
      "iconUrl":"https://jira.foo.com/images/icons/priorities/major.svg",
      "name":"Major",
      "id":"3"
    },
    "labels":[
      "Lizzy",
      "kanban",
      "rughani"
    ],
    "updated":"2021-01-21T10:33:38.000+0000",
    "status":{
      "self":"https://jira.foo.com/rest/api/2/status/1",
      "description":"The issue is open and ready for the assignee to start work on it.",
      "iconUrl":"https://jira.foo.com/images/icons/statuses/open.png",
      "name":"Open",
      "id":"1",
      "statusCategory":{
        "self":"https://jira.foo.com/rest/api/2/statuscategory/2",
        "id":2,
        "key":"new",
        "colorName":"blue-gray",
        "name":"To Do"
      }
    },
    "summary":"new epic for Tazzy",
    "creator":{
      "self":"https://jira.foo.com/rest/api/2/user?username=skadmin",
      "name":"skadmin",
      "key":"skadmin",
      "emailAddress":"Lizzy.t@foo.com",
      "displayName":"Lizzy Rughani",
      "active":true,
      "timeZone":"Asia/Kolkata"
    },
    "subtasks":[

    ],
  }
}

我对这里的三个嵌套值感兴趣，我试图通过以下表达式获取

issueDataMap = {LinkedHashMap@4867}  size = 3
 "name" -> "#payload['fields']['summary']"
 "description" -> "#payload['description']"
 "text3" -> "#payload['key']"

应用表达式时出现此错误

org.springframework.expression.spel.SpelEvaluationException: EL1012E: Cannot index into a null value

这是我如何在我的转换器的 as 参数中获取有效负载

@Transformer
public Map<String, Object> generateCardData(Map<String, Object> payload,
                                            @Header("X-UPSTREAM-WEBHOOK-SOURCE") String projectId) {

其次是

StandardEvaluationContext evaluationContext = evaluationContextFactory.getObject();

这就是我评估它的方式

new SpelExpressionParser().parseExpression(issueDataMap.get(key)).getValue(
                            evaluationContext, payload, String.class)));

我有一个用@SpringBootApplicationand注释的应用程序@EnableInegration，我自动装配一个实例IntegrationEvaluationContextFactoryBean来获取StandardEvaluationContext

我也尝试了变体

issueDataMap = {LinkedHashMap@4867}  size = 3
 "name" -> "payload['fields']['summary']"
 "description" -> "payload['description']"
 "text3" -> "payload['key']"

但后来我得到

EL1008E: Property or field 'payload' cannot be found on object of type 'java.util.LinkedHashMap' - maybe not public or not valid?

标签： javaspring-bootspring-integrationspring-expression-language

解决方案

首先，当您拥有对对象的完全访问权限时，不清楚为什么要手动在代码中使用 SpEL。另外，您应该记住，StandardEvaluationContext在每次调用时创建、解析表达式并对其进行评估对性能来说是一种开销。您可能只需要更改generateCardData()签名以接受表达式的结果而不是整个地图。见@Payload.expression属性。

无论如何，这不是你想听到的你的问题。它在这里： getValue(evaluationContext, payload, String.class)))。根评估对象是 your payload-a Map。因此，您只需要在表达式定义中假设您可以访问该根对象。因此表达式必须是这样的：fields.summary, description, key.

您通常会在文档和示例中看到 a payload(or header) 作为表达式中的第一个标记。那只是因为 Spring Integration 使用 aMessage作为表达式求值的根对象。

现在关于性能。即使您的逻辑是在运行时（issueDataMap.get(key)）通过某个键选择表达式，您仍然只能解析一次。

推荐阅读