以下是一个使用Python的示例代码,该代码可以按照id将Kibana的结果进行分组:
import requests
def group_kibana_results_by_id():
# 发送GET请求获取Kibana的结果
response = requests.get('https://kibana.example.com/api/search')
if response.status_code == 200:
# 解析响应的JSON数据
data = response.json()
# 创建一个字典来存储分组后的结果
grouped_results = {}
# 遍历Kibana的结果
for result in data['hits']['hits']:
# 获取结果的id
result_id = result['_id']
# 检查字典中是否已存在该id对应的结果列表
if result_id in grouped_results:
# 如果存在,则将结果添加到对应的列表中
grouped_results[result_id].append(result)
else:
# 如果不存在,则创建一个新的结果列表,并将结果添加到列表中
grouped_results[result_id] = [result]
return grouped_results
else:
# 处理请求失败的情况
print('Failed to retrieve Kibana results. Status code:', response.status_code)
return None
# 调用函数并打印结果
results = group_kibana_results_by_id()
if results:
for result_id, result_list in results.items():
print(f"ID: {result_id}")
for result in result_list:
print(result)
print('---')
这个示例代码使用了请求库requests
来发送GET请求获取Kibana的结果。然后,遍历结果并根据id将其分组存储在一个字典中。最后,按照分组打印结果。
请注意,示例中的URL https://kibana.example.com/api/search
是一个示例URL,你需要将其替换为你自己的Kibana搜索API的URL。
上一篇:按ID将多行转换为一行
下一篇:按id将前n个频繁值转置为列