使用Dataweave 2.0将JSON对象展开为嵌套JSON对象

如何解决使用Dataweave 2.0将JSON对象展开为嵌套JSON对象

我有这个展平的对象

{
  "abc.def.ghi": "foo","abc.def.jkl": "bar"
}

我想编写一个数据编织将其转换为原始对象,即

{
  "abc": {
    "def": {
      "ghi": "foo","jkl": "bar"
    }
  }
}

我试图避免对密钥进行硬编码,因为它是一个很大的对象,所以我不想要这样的东西:

%dw 2.0
var test = {
    "abc.def.ghi": "foo","abc.def.jkl": "bar"
}
output application/json
---
{
    abc: {
        def: {
            ghi: test."abc.def.ghi",jkl: test."abc.def.jkl"
        }
    }
}

我可以使用一些可用的dataweave函数的组合来实现这一点吗?

这是我到目前为止尝试过的:

%dw 2.0
var test = {
    "abc.def.ghi": "foo","abc.def.jkl": "bar"
}
output application/json
---
test mapObject ((value,key) -> 
    (key as String splitBy  ".")[-1 to 0]  
         reduce ((item,acc = value) -> 
             (item): acc     
/*
   First item=ghi,acc=foo => acc = {ghi: "foo"} 
   next item=def,acc={ghi: "foo"} => acc={def:{ghi:"foo"}}
*/
    )
)

但是,这将生成某种单独的嵌套JSON对。这是上面代码的输出:

{
  "abc": {
    "def": {
      "ghi": "foo"
    }
  },"abc": {
    "def": {
      "jkl": "bar"
    }
  }
}

解决方法

您可以根据Mohammad Mazhar Ansari撰写的这篇Apisero文章尝试以下数据编织表达式:https://apisero.com/property-to-yaml-file-conversion-using-mulesoft/

%dw 2.0
var test = {
    "abc.def.ghi": "foo","abc.def.jkl": "bar"
}
import * from dw::core::Strings
output application/json
fun generateArray (obj) = obj pluck (v,k) -> (k): v
fun isSubChildExists (key) = (((key) splitBy ("."))[1] != null)
fun propToJSON(key,value) = if (isSubChildExists(key)) {
   (substringBefore(key,".")) : propToJSON(substringAfter(key,"."),value)
}
else
   (key): value
fun arrToObj(arr) = arr reduce ((env,obj={}) -> obj ++ env)
fun CombineObjBasedOnKey (Obj) =
if (typeOf(Obj) == Array and sizeOf(Obj..) > 1)
((Obj groupBy (item,index) -> keysOf(item)[0]) mapObject ((value,key,index) ->
   (if (typeOf(value) == Array)
       (key): CombineObjBasedOnKey(value..'$key')
   else if (typeOf(value) == String)
       value
   else
       (key): value
) as Object))
else
   Obj[0]
---
CombineObjBasedOnKey(generateArray(test) map ((item,index) -> item mapObject ((value,index) -> propToJSON((key),value))
))

输出:

{
  "abc": {
    "def": {
      "ghi": "foo","jkl": "bar"
    }
  }
}
,

另一种方法是使用4.3中引入的 update 运算符。使用此运算符,我们可以进行upsert(不存在时插入值,如果存在则进行更新)。使用该操作和reduce可以从表达式的每个部分开始进行正确的更新

%dw 2.0
output application/json
import * from dw::util::Values


fun upsert(object: {},path:Array<String>,value: Any): Object = do {
    path match {
        case [] -> object
        case [x ~ xs] -> 
                if(isEmpty(xs))
                    object update  {
                        case ."$(x)"! -> value                                
                    }
                else
                    object update  {
                        case selected at ."$(x)"! -> 
                            //selected is going to be null when the value is not present  
                            upsert(selected default {},xs,value)
                    }  
    }
}
---
payload 
    pluck ((value,index) -> {key: key,value: value})
    reduce ((item,resultObject = {} ) -> do {
        upsert(resultObject,(item.key as String splitBy '.'),item.value)
    })
,

这类似于@olamiral解决方案,但经过简化并支持数组。

x   <- floor(runif(50,40))

具有此有效载荷:

g1 <- (x >= 0) & (x<= 10)
g2 <- (x >= 11) & (x<= 20)
g3 <- (x >= 21) & (x<= 30)
g4 <- (x>= 31)

正在产生以下输出:

%dw 2.0
output application/json

// Creates a array of key-value tuples with the object structure. 
// I was not able to use entriesOf() because I had to modify the key to split it
var tuples = payload pluck ((value,index) -> 
    { 
        k: key splitBy("."),v: value}
    )

// Using groupBy,group the childs and maps to an object structure.
fun flatToObject(tuples,index) =
    (tuples groupBy $.k[index]) mapObject ((groupedTuples,idx) -> 
        if(groupedTuples[0].k[index + 1]?) 
            // Has more levels
            { (key): flatToObject(groupedTuples,index + 1) }
        else 
            // It's a leaf
            { (key): if (sizeOf(groupedTuples.v) > 1)
                    // It has an array of values
                    groupedTuples.v 
                else 
                    // It has a single value
                    groupedTuples.v[0]
            }
    )
---
flatToObject(tuples,0)

此解决方案不支持在同一数组中混合简单值和对象。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


依赖报错 idea导入项目后依赖报错,解决方案:https://blog.csdn.net/weixin_42420249/article/details/81191861 依赖版本报错:更换其他版本 无法下载依赖可参考:https://blog.csdn.net/weixin_42628809/a
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下 2021-12-03 13:33:33.927 ERROR 7228 [ main] o.s.b.d.LoggingFailureAnalysisReporter : *************************** APPL
错误1:gradle项目控制台输出为乱码 # 解决方案:https://blog.csdn.net/weixin_43501566/article/details/112482302 # 在gradle-wrapper.properties 添加以下内容 org.gradle.jvmargs=-Df
错误还原:在查询的过程中,传入的workType为0时,该条件不起作用 &lt;select id=&quot;xxx&quot;&gt; SELECT di.id, di.name, di.work_type, di.updated... &lt;where&gt; &lt;if test=&qu
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct redisServer’没有名为‘server_cpulist’的成员 redisSetCpuAffinity(server.server_cpulist); ^ server.c: 在函数‘hasActiveC
解决方案1 1、改项目中.idea/workspace.xml配置文件,增加dynamic.classpath参数 2、搜索PropertiesComponent,添加如下 &lt;property name=&quot;dynamic.classpath&quot; value=&quot;tru
删除根组件app.vue中的默认代码后报错:Module Error (from ./node_modules/eslint-loader/index.js): 解决方案:关闭ESlint代码检测,在项目根目录创建vue.config.js,在文件中添加 module.exports = { lin
查看spark默认的python版本 [root@master day27]# pyspark /home/software/spark-2.3.4-bin-hadoop2.7/conf/spark-env.sh: line 2: /usr/local/hadoop/bin/hadoop: No s
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-