无痛脚本弹性搜索观察器的问题

Question

我在elasticsearch中创建了一个观察器，当我们在索引中10分钟没有新条目或事件时，它会报告，这可以通过查看条目中的源字段来进一步划分。

我只得到了索引的最后10分钟，并查看了桶中不存在哪个源。

为此，我首先创建我们收到的所有源类型的列表，然后从返回的存储桶键创建一个列表。然后，我想比较列表以查看缺少哪个列表，然后将其传递到消息中。

我在for循环中遇到了一个通用错误。任何反馈对弹性和无痛都很有帮助，所以可能是我错过的简单的东西。

"transform": {
          "script": {
            "source": """String vMessage = 'Clickstream data has been loaded although there are no iovation records from the following source in the last 10 mins:

';if(ctx.payload.clickstream.hits.total > 0 && ctx.payload.iovation.aggregations.source.buckets.size() < 3) { source_list = ['wintech', 'login', 'clickstream']; source_array = new String[] for (source in ctx.payload.iovation.aggregations.source.buckets){ source_array.add(source.key);  } for (key in source_list){ if (!source_array.contains(key){ vMessage += '<ul><li>' + key + '</li></ul>';}  } }return [ 'message': vMessage ];""",
            "lang": "painless"
          }
        },

Answer 1

所以我在挖掘了更多的文档后发现了这一点。

我错误地声明了我的列表。要声明列表，它需要采用如下格式。

 List new_list = new ArrayList();

这解决了我的问题，现在转换脚本按预期工作。

"""String vMessage = 'Clickstream data has been loaded although there are no iovation records from the following source in the last 10 mins:

';if(ctx.payload.clickstream.hits.total > 0 && ctx.payload.iovation.aggregations.source.buckets.size() < 3) { List source_list = new ArrayList(['wintech', 'login', 'clickstream']); List source_array = new ArrayList(); for (source in ctx.payload.iovation.aggregations.source.buckets){ source_array.add(source.key);  } for (key in source_list){ if (!source_array.contains(key)){ vMessage += '<ul><li>' + key + '</li></ul>';}  } }return [ 'message': vMessage ];""",