需要数据编织帮助进行转换

如何解决需要数据编织帮助进行转换

我在下面输入

[
  {
    "CloudAccountDetail": {
      "CompanyCode": "B_B001","CloudAccountId": "a-t-1000-5001-0687-0024","CloudAccountPublicName": "dodp-testcloud","Status": "SUBSCRIBED","ClusterName": "ci.dev.cloudi.city"
    },"NamedSubscriptions": [
      {
        "SubscriptionId": "8f724cc9-bb21-43bc-8911-94d267eb7917","OrderNumber": "TEST708259","StartDate": "2020-01-07T12:13:19.507","ExpiryDate": "2021-01-16T00:00:00","CanceledDate": null,"ProductCode": "ECL-SA-PUSR","ProductName": "Esko Cloud Power User","Assignee": "eskododp03@yahoo.be","AssignedBy": "LicenseService","AssignedDate": "2020-01-07T11:16:52.723","EskoCloudAccount": "a-t-1000-5001-0687-0024","Status": "ACTIVE"
      },{
        "SubscriptionId": "5c06112a-90a4-4e76-b2f4-bd19a1ce92b3","Assignee": null,"AssignedBy": null,"AssignedDate": null,{
        "SubscriptionId": "a258a7fc-cff6-4b53-b19d-4e25a8dbcee6",{
        "SubscriptionId": "e30f16af-de60-4b84-bdae-aa7b6523c316",{
        "SubscriptionId": "5ee9eeb6-9d65-42b8-b594-68c9528ff25b","StartDate": "2020-01-07T12:13:20.507",{
        "SubscriptionId": "818b38f1-0a10-45dc-ae16-f7d804b31cbc",{
        "SubscriptionId": "cf5fc421-8ee0-4f1f-a1ca-e64daef2e0c6","Status": "ACTIVE"
      }
    ],"UnnamedSubscriptions": [
      {
        "SubscriptionId": "c56c5d21-83dd-4df5-851c-52fd5686240b","StartDate": "2020-01-07T13:23:02.593","ProductCode": "ECL-SA-SITE","ProductName": "Share & Approve Site",{
        "SubscriptionId": "1d5bf54c-e812-4c17-830d-d3a1104d66a5",{
        "SubscriptionId": "fbe0bbef-3cc2-451a-9866-0bb31a829850",{
        "SubscriptionId": "368fa144-5a94-4ead-ba69-502ca6419de4",{
        "SubscriptionId": "3404fb6e-d234-4dac-a5a1-96c7534ccf21","StartDate": "2020-01-07T13:23:03.593",{
        "SubscriptionId": "71d88ad6-3108-499e-8be9-3638c7298770",{
        "SubscriptionId": "992b551e-1499-4971-bc9b-34075820faa7","StorageSubscriptions": [
      {
        "EntitlementId": "5ceae026-5c3e-40df-a9f8-2de4f4570566","StorageInGb": 50,"ExpiryDate": "2021-01-07T00:00:00","StartDate": "2020-01-07T12:37:12.697","ProductCode": "ECL-ECL-ST-ST50","ProductName": "Storage Tier 1 (50GB)","TransactionSubscriptions": [
      {
        "EntitlementId": "6eaf4b93-8fef-4423-88fd-7e83d790f6f7","NumberOfTransactions": 12000,"StartDate": "2020-01-07T12:17:56.257","ProductCode": "ECL-ECL-BTR-BTR1000","ProductName": "Basic Transactions Tier 2 (1000/m)","Status": "ACTIVE"
      }
    ]
  },{
    "CloudAccountDetail": {
      "CompanyCode": "B_B001","CloudAccountId": "a-t-1001-0001-0039-0024","CloudAccountPublicName": "Test-Tom-Desmet","NamedSubscriptions": [
      {
        "SubscriptionId": "3dc289af-d469-4dba-875e-354c75d2a31a","OrderNumber": "TEST709894","StartDate": "2020-06-30T14:21:34.773","ExpiryDate": "2021-07-09T00:00:00","AssignedDate": "2020-06-30T13:31:01.777","EskoCloudAccount": "a-t-1001-0001-0039-0024",{
        "SubscriptionId": "3e6818fb-1c4f-4046-9783-5b76d3050eec","StartDate": "2020-06-30T14:21:35.773","UnnamedSubscriptions": [
      {
        "SubscriptionId": "baf3d5c7-b53e-460e-93a5-311b95924fca","StartDate": "2020-06-30T15:18:15.593",{
        "SubscriptionId": "69071fd1-59b5-44ef-a594-95141d68ef4c","StartDate": "2020-06-30T15:18:16.593","StorageSubscriptions": [
      {
        "EntitlementId": "f6f444e3-4dea-43d9-afc0-19d24200cf46","ExpiryDate": "2021-06-30T00:00:00","StartDate": "2020-06-30T14:57:54.05","TransactionSubscriptions": [
      {
        "EntitlementId": "22d25390-4183-4c89-8461-38ebf048812f","StartDate": "2020-06-30T14:24:10.017","Status": "ACTIVE"
      }
    ]
  }
]

我需要的输出如下。我无法创建分隔数组中的元素。

[
  {
    "key": "8f724cc9-bb21-43bc-8911-94d267eb7917","expiryDate": "2021-01-16"
  },{
    "key": "5c06112a-90a4-4e76-b2f4-bd19a1ce92b3",{
    "key": "a258a7fc-cff6-4b53-b19d-4e25a8dbcee6",{
    "key": "e30f16af-de60-4b84-bdae-aa7b6523c316",{
    "key": "5ee9eeb6-9d65-42b8-b594-68c9528ff25b",{
    "key": "818b38f1-0a10-45dc-ae16-f7d804b31cbc",{
    "key": "cf5fc421-8ee0-4f1f-a1ca-e64daef2e0c6",{
    "key": "c56c5d21-83dd-4df5-851c-52fd5686240b","expiryDate": "2021-01-16","cloudPublicName": "dodp-testcloud","cloudAccountId": "a-t-1000-5001-0687-0024"
  },{
    "key": "1d5bf54c-e812-4c17-830d-d3a1104d66a5",{
    "key": "fbe0bbef-3cc2-451a-9866-0bb31a829850",{
    "key": "368fa144-5a94-4ead-ba69-502ca6419de4",{
    "key": "3404fb6e-d234-4dac-a5a1-96c7534ccf21",{
    "key": "71d88ad6-3108-499e-8be9-3638c7298770",{
    "key": "992b551e-1499-4971-bc9b-34075820faa7",{
    "key": "3dc289af-d469-4dba-875e-354c75d2a31a","expiryDate": "2021-07-09"
  },{
    "key": "3e6818fb-1c4f-4046-9783-5b76d3050eec",{
    "key": "baf3d5c7-b53e-460e-93a5-311b95924fca","expiryDate": "2021-07-09","cloudPublicName": "Test-Tom-Desmet","cloudAccountId": "a-t-1001-0001-0039-0024"
  },{
    "key": "69071fd1-59b5-44ef-a594-95141d68ef4c","cloudAccountId": "a-t-1001-0001-0039-0024"
  }
  
]

解决方法

由于转换数据的规则尚不明确,我做了自己的尝试,似乎产生了预期的结果:

%dw 2.0
output application/json
---
flatten (
    payload map (item,order) -> (
        flatten ( [
            item.NamedSubscriptions map {
                key: $.SubscriptionId,expiryDate: $.ExpiryDate as Date
            },item.UnnamedSubscriptions map {
                key: $.SubscriptionId,expiryDate: $.ExpiryDate as Date,cloudPublicName: item.CloudAccountDetail.CloudAccountPublicName,cloudAccountId: item.CloudAccountDetail.CloudAccountId
            }
        ] )
    )  
)
,

使用 flatten 将删除数组的额外级别。

示例:

%dw 2.0
fun getSubscription(items) =
    (items default []) map {
        "key": $.SubscriptionId,"expiryDate": $.ExpiryDate as Date
    }
fun getUnsubscriptions(items,id,name) = 
    (items default []) map {
        "key": $.SubscriptionId,"expiryDate": $.ExpiryDate as Date,"cloudPublicName": name,"cloudAccountId": id
    }
output application/json
---
flatten (payload map (getSubscription($.NamedSubscriptions) ++ 
    getUnsubscriptions($.UnnamedSubscriptions,$.CloudAccountDetail.CloudAccountId,$.CloudAccountDetail.CloudAccountPublicName)))

使用功能 fun 将使其更整洁和可读性。

使用 flatMap 并重复使用一个函数来提取Named和UnnamedS订阅。

%dw 2.0
fun getData(items,account,isUnnamedSubscriptions) = 
    (items default []) map {
        "key": $.SubscriptionId,("cloudPublicName": account.CloudAccountPublicName) if (isUnnamedSubscriptions),("cloudAccountId": account.CloudAccountId) if (isUnnamedSubscriptions)
    }
output application/json
---
payload map (
    getData($.NamedSubscriptions,$.CloudAccountDetail,false)
    ++
    getData($.UnnamedSubscriptions,true)
) flatMap () -> $

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

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 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 -> 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("/hires") 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<String
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)> insert overwrite table dwd_trade_cart_add_inc > select data.id, > data.user_id, > data.course_id, > date_format(
错误1 hive (edu)> insert into huanhuan values(1,'haoge'); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive> show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 <configuration> <property> <name>yarn.nodemanager.res