使用 Mule 4 中的 DataWeave 转换嵌套 JSON 转换为 CSV

Question

我有这个转换消息：

%dw 2.0
output application/json
---
{
    "one": [
    "two": payload.one.two,
    "three": payload.one.three,
    "four": {
    "five": payload.one.four.five map (item, index) -> {
    five : item
     as DateTime 
     {format: "yyyy-MM-dd'T'HH:mm:ss.SSSxx"}
      as String {format: "yyyy-MM-dd"} 
},
    "six":{
        "seven": payload.one.four.six.seven,
        "eight": payload.one.four.six.eight
    },
        "nine": {
            "name": payload.one.four.nine.name
            
        },
    "tenCreated":payload.one.four.tenCreated map (item, index) -> {
    tenCreated : item
     as DateTime 
     {format: "yyyy-MM-dd'T'HH:mm:ss.SSSxx"}
      as String {format: "yyyy-MM-dd"},
      
      },
    "elevenUpdated": payload.one.four.elevenUpdated map (item, index) -> {
    elevenUpdated : item
     as DateTime 
     {format: "yyyy-MM-dd'T'HH:mm:ss.SSSxx"}
      as String {format: "yyyy-MM-dd"}
      
     },
    "twelve": {
        "thirteen": payload.one.four.twelve.thirteen
    },
    "fifteen": {
        "name": payload.one.four.fifteen.name
    },
    "sixteen":{
        "sixteenCreator": payload.one.four.sixteen.sixteenCreator,
        "seventeen": payload.four.one.sixteen.seventeen
    },
    "eieighteen": payload.one.four.eieighteen,
    "ninteen: {
        "ninteeneReporter": payload.one.four.ninteen.ninteeneReporter,
        "twentyEmail": payload.one.four.ninteen.twentyEmail
    },
    "twentyOne":{
        "TwentyTwo": payload.one.four.twentyOne.TwentyTwo,
        "TwnetyThree": payload.one.four.twentyOne.TwnetyThree
    },
    "TwentyFour": {
        "TwentyFive": payload.one.four.TwentyFour.TwentyFive,
        "TwentySix":{
            "TwentySeven": payload.one.four.TwentyFour.TwentySix.TwentySeven,
            "TwentyEight": payload.one.four.TwentyFour.TwentySix.TwentyEight.name,
            "Thiry": payload.one.four.TwentyFour.TwentySix.Thiry.name,
            "ThirtyOne": payload.isuues.four.TwentyFour.TwentySix.ThirtyOne.name
        }   
    }
    }
    
    ] reduce (element,acc={}) -> acc ++ element
}

此转换消息作为输出如下所示：

{
    "one": {
        "two": [
             "199052",
            "109926"
        
         
        ],
        "three": [
            "191",
            "190",
            "189",
            "188",
            "187"
       
        ],
        "four": {
            "five": [
                {
                    "five": "2022-03-24"
                },
                {
                    "five": "2022-03-24"
                },
                {
                    "five": "2022-03-18"
                },
                {
                    "five": "2022-03-18"
                },
                {
                    "five": "2022-03-18"
                },
                {
                    "five": "2022-03-14"
                },
                {
                    "five": "2022-03-14"
                },
            
            ],
            "six": {
                "seven": [
                   "Test1",
                    "Test2",
                     "Test1",
                    "Test2"
       
                ],
                "eight": [
                   "first description.",
                    "second description",
                     "first description.",
                    "second description"
                  
                ]
            },
            "nine": {
                "name": [
                     "Ps3564",
                    "35355Ps"
                 
       
           
                ]
            },
            "tenCreated": [
                
                {
                    "tenCreated": "2022-02-10"
                },
                {
                    "tenCreated": "2022-02-10"
                },
                {
                    "tenCreated": "2022-02-10"
                }
            ],
            "elevenUpdated": [
                {
                    "elevenUpdated": "2022-03-24"
                },
                {
                    "elevenUpdated": "2022-03-24"
                },
                {
                    "elevenUpdated": "2022-03-24"
                },
            ],
            "twelve": {
                "thirteen": [
                    "fourteen",
                    "Do",
                    "Do again",
                    "Do work",
                    "Doone"

                ]
            },
            "fifteen": {
                "name": [
                   "Good",
                    "Not good",
                    "good"
              
                ]
            },
            "sixteen": {
                "sixteenCreator": [
                  "Jan Kowalski",
                    "Jan kowalski",
                     "Jan Kowalski",
                    "Jan kowalski"
        
                ],
                "seventeen": null
            },
            "eieighteen": [
               "Test test",
                "test test 10",
                "api test",
         
             
                
            ],
            "ninteen": {
                "ninteeneReporter": [
                  "Jan Kowalski",
                    "Jan Kowalski",
                    "Jan Kowalski"
                  
                    
                ],
                "twentyEmail": [
                "jankowalski@",
                    "jankowalski@"
              
                ]
            },
            "twentyOne": {
                "TwentyTwo": [
                "Jan Kowalski",
                    "Jan Kowalski",
                    "Jan Kowalski"
                   
                
                ],
                "TwnetyThree": [
                   "jankowalski@",
                    "jankowalski@"
                 
                ]
            },
            "TwentyFour": {
                "TwentyFive": [
                    "P186",
                    "P186",
                    "P186",
                 
                ],
                "TwentySix": {
                    "TwentySeven": [
                        "Plan",
                        "Plan",
                        "Plan"
                     
             
                    ],
                    "TwentyEight": [
                         "END",
                        "END"
                 
                    ],
                    "Thiry": [
                        "To Do",
                        "To Do",
                        "To Do",
                        "To Do",
                  
                    ],
                    "ThirtyOne": null
                }
            }
        }
    }
}

如何使用转换消息将此结构转换为 CSV？

我希望我的 csv 看起来像这样（这只是示例）：

two;three;four;five
199052;191;2022-03-24
109926;191;2022-03-24
       190;2022-03-24
       189;2022-03-24
       188;2022-03-24
       187;2022-03-24
          2022-03-24

Answer 1

我假设输出应该是一致的，所以我结合了我以前的一些答案并创建了这个可重用函数来概括从不同长度的数组生成 CSV（或基于记录的输出）的方法。

%dw 2.0
output application/csv  separator=";", header=true

// Converts an object with each value is an array to an array with key pairs useful to be used for emitting a CSV output
fun ObjectToRecords(o)=do {
    var columns = namesOf(o)
    var maxColumnSize = max(columns map sizeOf(o[$]))
    var maxColumnName = columns dw::core::Arrays::firstWith (sizeOf(o[$]) == maxColumnSize)
    ---
    o[maxColumnName] 
        map ((item, index) -> ( 
            columns map ($): o[$][index]) 
                reduce ($$++$) 
        )
}

var payload2 = {
  two: payload.one.two,
  three: payload.one.three,
  four: payload.one.four.five.five,
  five: []
}
---
ObjectToRecords(payload2)

输出：

two;three;four;five
199052;191;2022-03-24;
109926;190;2022-03-24;
;189;2022-03-18;
;188;2022-03-18;
;187;2022-03-18;
;;2022-03-14;
;;2022-03-14;

使用 Mule 4 中的 DataWeave 转换嵌套 JSON 转换为 CSV

Convert nested JSON convert to CSV with DataWeave in Mule 4

csv

mule

anypoint-studio

dataweave

mule4