elasticsearch - 在 Spring Batch 中使用 Elasticsearch java config 客户端

Question

我正在尝试编写一个自定义的 Elasticsearch 编写器，它将在 Spring 批处理实现中索引数据。

我可以找到以下代码作为 Elasticsearch 的 Java 配置。

有人用过这个，可以分享一下这个配置在哪里调用吗？

@Configuration
   @EnableElasticsearchRepositories(basePackages = "org/springframework/data/elasticsearch/repositories")
        static class Config {

        @Value("${esearch.port}") int port;
        @Value("${esearch.host}") String hostname;

        @Bean
        public ElasticsearchOperations elasticsearchTemplate() {
        return new ElasticsearchTemplate(client());
         }

        @Bean
        public Client client(){
            TransportClient client= new TransportClient();
            TransportAddress address = new InetSocketTransportAddress(hostname, port); 
            client.addTransportAddress(address);
            return client;
        }
   }

Answer 1

您上面列出的代码基本上是指向 Elasticsearch Server 实例的传输客户端元素的实现细节，即它使用 Spring Data 定义了您的持久层。

此代码将由您的 elasticsearch 存储库使用，即您通过扩展定义的存储库 - ElasticsearchRepository来自 Spring 数据。

您需要编辑@EnableElasticsearchRepositories在您列出的代码中实际指向您保存存储库定义的包 - 不需要其他调用。

当您要将数据写入/索引到 elasticsearch 时，您使用 ElasticsearchRepository接口(interface)，您需要定义自己的存储库，这些存储库根据代码中的列表与实例一起使用。

希望能帮助到你 !!