Elastic Search（ES）Java 入门实操数据同步

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
 
// 假设已经有了一个RestHighLevelClient实例client
 
public void syncDataToElasticsearch(RestHighLevelClient client, String indexName, String jsonData) {
    try {
        IndexRequest request = new IndexRequest(indexName);
        // 可以设置id，如果不设置则ES自动生成
        String id = "1";
        request.id(id);
        // 设置数据
        request.source(jsonData, XContentType.JSON);
        // 执行索引操作
        client.index(request, RequestOptions.DEFAULT);
        System.out.println("数据同步成功，索引名称：" + indexName + "，文档ID：" + id);
    } catch (Exception e) {
        System.out.println("数据同步失败：" + e.getMessage());
    }
}

这段代码展示了如何将一个JSON格式的字符串数据同步到Elasticsearch中。首先创建了一个IndexRequest对象，并设置了索引名和文档ID。然后通过source方法设置了要索引的数据，并指定数据的格式为JSON。最后，使用RestHighLevelClient实例的index方法执行索引操作。如果操作成功，会打印出相应的信息；如果操作失败，会捕获异常并打印错误信息。