在kibana 6中创建可视化的Java api

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>6.8.0</version>
</dependency>

import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;

public class KibanaVisualizer {
    private RestHighLevelClient client;

    public KibanaVisualizer() {
        client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http")));
    }
}

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.aggregations.metrics.sum.Sum;
import org.elasticsearch.search.builder.SearchSourceBuilder;

public class KibanaVisualizer {
    // ...

    public void createBarChartVisualization() {
        SearchRequest searchRequest = new SearchRequest("your_index_name");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
        searchSourceBuilder.aggregation(
                AggregationBuilders.terms("by_category").field("category.keyword")
                        .subAggregation(AggregationBuilders.sum("total_sales").field("sales")));
        searchRequest.source(searchSourceBuilder);

        try {
            SearchResponse searchResponse = client.search(searchRequest);
            Terms byCategoryAggregation = searchResponse.getAggregations().get("by_category");

            for (Terms.Bucket bucket : byCategoryAggregation.getBuckets()) {
                String category = bucket.getKeyAsString();
                Sum totalSales = bucket.getAggregations().get("total_sales");
                double sales = totalSales.getValue();

                // 处理每个分类的销售总额
                System.out.println("Category: " + category + ", Total Sales: " + sales);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}