elasticsearch - Jolt 递归变换如何展平-6ren

elasticsearch - Jolt 递归变换如何展平

转载作者：行者123 更新时间：2023-12-02 22:19:56

25

4

我有以下 Elasticsearch 结果:

{
    "took": 16,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "failed": 0
    },
    "hits": {
        "total": 77753,
        "max_score": 0,
        "hits": []
    },
    "aggregations": {
        "my_agg1": {
            "doc_count_error_upper_bound": 0,
            "sum_other_doc_count": 0,
            "buckets": [
                {
                    "key": "a",
                    "doc_count": 77739,
                    "my_agg2": {
                        "doc_count_error_upper_bound": 0,
                        "sum_other_doc_count": 0,
                        "buckets": [
                            {
                                "key": 777,
                                "doc_count": 77721,
                                "my_agg3": {
                                    "doc_count_error_upper_bound": 0,
                                    "sum_other_doc_count": 0,
                                    "buckets": [
                                        {
                                            "key": "1234",
                                            "doc_count": 48889
                                        },
                                        {
                                            "key": "5678",
                                            "doc_count": 25439
                                        },
                                        {
                                            "key": "9101",
                                            "doc_count": 3193
                                        },
                                        {
                                            "key": "9111",
                                            "doc_count": 196
                                        }
                                    ]
                                }
                            },
                            {
                                "key": 888,
                                "doc_count": 17,
                                "my_agg3": {
                                    "doc_count_error_upper_bound": 0,
                                    "sum_other_doc_count": 0,
                                    "buckets": [
                                        {
                                            "key": "1234",
                                            "doc_count": 9
                                        },
                                        {
                                            "key": "1233",
                                            "doc_count": 4
                                        },
                                        {
                                            "key": "1244",
                                            "doc_count": 3
                                        },
                                        {
                                            "key": "1230",
                                            "doc_count": 1
                                        }
                                    ]
                                }
                            },
                            {
                                "key": 999,
                                "doc_count": 1,
                                "my_agg3": {
                                    "doc_count_error_upper_bound": 0,
                                    "sum_other_doc_count": 0,
                                    "buckets": [
                                        {
                                            "key": "1261",
                                            "doc_count": 1
                                        }
                                    ]
                                }
                            }
                        ]
                    }
                },
                {
                    "key": "s",
                    "doc_count": 6,
                    "my_agg2": {
                        "doc_count_error_upper_bound": 0,
                        "sum_other_doc_count": 0,
                        "buckets": [
                            {
                                "key": 888,
                                "doc_count": 6,
                                "my_agg3": {
                                    "doc_count_error_upper_bound": 0,
                                    "sum_other_doc_count": 0,
                                    "buckets": [
                                        {
                                            "key": "1200",
                                            "doc_count": 4
                                        },
                                        {
                                            "key": "1210",
                                            "doc_count": 1
                                        },
                                        {
                                            "key": "1216",
                                            "doc_count": 1
                                        }
                                    ]
                                }
                            }
                        ]
                    }
                }
            ]
        }
    }
}

我想平铺成这样的 table ......

a, 777, 1234
a, 777, 5678
a, 777, 9101
a, 777, 9111
a, 888, 1234
a, 888, 1233
a, 888, 1244
a, 888, 1230
a, 999, 1261
s, 888, 1200
s, 888, 1210
s, 888, 1216

震动可以吗？

最佳答案

实际上，它可以制作“csv”样式的输出，但它需要两次 Shift。第一个转换为每个“agg”构建数据，然后第二个转换将它们转换为输出数组。

规范

[
  {
    "operation": "shift",
    "spec": {
      "aggregations": {
        "my_agg1": {
          "buckets": {
            "*": {
              "my_agg2": {
                "buckets": {
                  "*": {
                    "my_agg3": {
                      "buckets": {
                        "*": {
                          "key": "agg3[]",
                          "@(3,key)": "agg2[]",
                          "@(6,key)": "agg1[]"
                        }
                      }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  },
  {
    "operation": "shift",
    "spec": {
      "agg1": {
        "*": "[&][0]"
      },
      "agg2": {
        "*": "[&][1]"
      },
      "agg3": {
        "*": "[&][2]"
      }
    }
  }
]

生产

[ 
  [ "a", 777, "1234" ], 
  [ "a", 777, "5678" ], 
  [ "a", 777, "9101" ], 
  [ "a", 777, "9111" ], 
  [ "a", 888, "1234" ], 
  [ "a", 888, "1233" ], 
  [ "a", 888, "1244" ], 
  [ "a", 888, "1230" ], 
  [ "a", 999, "1261" ], 
  [ "s", 888, "1200" ], 
  [ "s", 888, "1210" ], 
  [ "s", 888, "1216" ] 
]

关于elasticsearch - Jolt 递归变换如何展平，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34139209/

25

4

0

文章推荐： javascript - 无法从后置函数编辑全局变量

文章推荐： Always block 中的 Verilog 递归

文章推荐： javascript - React useState 导致渲染循环

JavaScript 递归
在本教程中，您将借助示例了解 JavaScript 中的递归。递归是一个调用自身的过程。调用自身的函数称为递归函数。递归函数的语法是： function recurse() {
'new'方法中的C#递归
我的类(class) MyClass 中有这段代码: public new MyClass this[int index] { get {
PHP通过FTP下载整个文件夹(递归)
我目前有一个非常大的网站，大小约为 5GB，包含 60,000 个文件。当前主机在帮助我将站点转移到新主机方面并没有做太多事情，我想的是在我的新主机上制作一个简单的脚本以 FTP 到旧主机并下载整个
Java - 递归
以下是我对 AP 计算机科学问题的改编。书上说应该打印00100123我认为它应该打印 0010012但下面的代码实际上打印了 3132123 这是怎么回事？而且它似乎没有任何停止条件？! publi
Kotlin 递归
fun fact(x: Int): Int{ tailrec fun factTail(y: Int, z: Int): Int{ if (y == 0) return z
在C中创建和显示线性链表(递归)
我正在尝试用c语言递归地创建线性链表，但继续坚持下去，代码无法正常工作，并出现错误“链接器工具错误 LNK2019”。可悲的是我不明白发生了什么事。这是我的代码。感谢您提前提供的大力帮助。 #inc
JavaScript 递归？
我正在练习递归。从概念上讲，我理解这应该如何工作(见下文)，但我的代码不起作用。请告诉我我做错了什么。并请解释您的代码的每个步骤及其工作原理。清晰的解释比只给我有效的代码要好十倍。 /* b
Javascript 递归
我有一个 ajax 调用，我想在完成解析并将结果动画化到页面中后调用它。这就是我陷入困境的地方。我能记忆起这个功能，但它似乎没有考虑到动画的延迟。即控制台不断以疯狂的速度输出值。我认为 setIn
JavaScript 递归
有人愿意用通俗易懂的语言逐步解释这个程序(取自书籍教程)以帮助我理解递归吗？ var reverseArray = function(x,indx,str) { return indx == 0 ?
JavaScript 递归
目标是找出数组中整数的任意组合是否等于数组中的最大整数。 function ArrayAdditionI(arr) { arr.sort(function(a,b){ return a -
MySQL用序列化数据连接两个表，递归？
我在尝试获取 SQL 查询所需的所有数据时遇到一些重大问题。我对查询还很陌生，所以我会尽力尽可能地描述这一点。我正在尝试使用 Wordpress 插件 NextGen Gallery 进行交叉查询。
Python:递归
虽然网上有很多关于递归的信息，但我还没有找到任何可以应用于我的问题的信息。我对编程还是很陌生，所以如果我的问题很微不足道，请原谅。感谢您的帮助:) 这就是我想要的结果: listVariations
C练习任务(递归)
我一整天都在为以下问题而苦苦挣扎。我一开始就有问题。我不知道如何使用递归来解决这个特定问题。我将非常感谢您的帮助，因为我的期末考试还有几天。干杯假设有一个包含“n”个元素的整数数组“a”。编写递归函
Javascript 递归
我有这个问题我想创建一个递归函数来计算所有可能的数字 (k>0)，加上数字 1 或 2。数字 2 的示例我有两个可能性。 2 = 1+1 和 2 = 2 ，对于数字 3 两个 poss。 3 = 1+
以Top-Down思维去解决问题——递归
目录递归的基础递归的底层实现（不是重点）递归的应用场景编程中两种解决问题的思维自下而上（Bottom-Up）自上而下（Top-
Python数据结构与算法（4.1）——递归
0. 学习目标递归函数是直接调用自己或通过一系列语句间接调用自己的函数。递归在程序设计有着举足轻重的作用，在很多情况下，借助递归可以优雅的解决问题。本节主要介绍递归的基本概念以及如何构建递归程序。
php - 数组中所有可能的组合 - 递归？
我有一个问题一直困扰着我，希望有人能提供帮助。我认为它可能必须通过递归和/或排列来解决，但我不是一个足够好的 (PHP) 程序员。 $map[] = array("0", "1", "2", "3")
用 dplyr 递归
我有数据 library(dplyr, warn.conflicts = FALSE) mtcars %>% as_tibble() %>% select(mpg, qsec) %>% h
kdb - q - 递归/
在 q 中，over 的常见插图运算符(operator) /是 implementation of fibonacci sequence 10 {x,sum -2#x}/ 1 1 这确实打印了前 1
methods - 递归 - 一个语句中的两个调用
我试图理解以下代码片段中的递归调用。 static long fib(int n) { return n <= 1 ? n : fib(n-1) + fib(n-2); } 哪个函数调用首先被

首页

博学

6Ren·AI

商城

elasticsearch - Jolt 递归变换如何展平