Данные индексируются в упругом поиске с использованием верблюда, но их невозможно увидеть в Kibana или localhost: 9200

Question

Я пытаюсь вставить некоторые данные против некоторого идентификатора в упругий поиск, используя верблюда Apache.Я вставил зависимость:

<dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-elasticsearch</artifactId>
</dependency>

Я использую JSONObject следующим образом:

{
"indexId" : "someId",
"messages" : {"message1" : "data1", "message2":"data2"}

}

И данные вставляются с использованием:

<to id="elastic_search_camel"
                uri="elasticsearch://local?operation=INDEX&amp;indexName=messages&amp;indexType=message" />

Я также могу распечатать данные обратно на консоли, используя операцию = GET_BY_ID.Но я не могу увидеть индекс / данные в Kibana или localhost: 9200.

Может кто-нибудь помочь мне в этом?Заранее спасибо.

Answer 1

Я использовал Apache Camel для подключения к серверу ElasticSearch.Camel создает свой собственный кластер эластичного поиска, поэтому он не подключался к моему текущему серверу.Чтобы остановить это конкретное поведение, необходимо явно указать IP-адрес и порт при создании uri:

<to id="elastic_search_camel"
                uri="elasticsearch://<clusterName>?operation=INDEX&amp;indexName=messages&amp;indexType=doc&amp;ip=x.x.x.x&amp;port=9300" />

Примечание. Аргумент transportAddresses также можно использовать для указания списка формата ip: port.За подробностями обращайтесь к http://camel.apache.org/elasticsearch.html.

Укажите то же самое в файле config /asticsearch.yml:

http.port: 9200
network.host: x.x.x.x
cluster.name: <clusterName>
network.bind_host: 0

Зависимости в maven:

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-elasticsearch</artifactId>
</dependency>
<dependency>
    <groupId>net.java.dev.jna</groupId>
    <artifactId>jna</artifactId>
    <version>4.1.0</version>
</dependency>

В качестве опции для упругого поиска можно также использовать упор для поиска упругого поиска.Где маршрут может быть указан как:

<to id="elastic_search_camel"
            uri="elasticsearch-rest://<clusterName>?operation=INDEX&amp;indexName=messages&amp;indexType=doc&amp;hostAddresses=x.x.x.x:9200" />

Документация доступна на: Упругий поиск Остальные

Maven dependencies : 
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-elasticsearch-rest</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-elasticsearch-rest-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>net.java.dev.jna</groupId>
            <artifactId>jna</artifactId>
            <version>4.1.0</version>
        </dependency>

Answer 2

вам нужно проверить, что индекс существует - вы можете запустить

GET es-url: 9200 / _cat / indices / messages *

и убедиться, чтоИндекс существует.если индекс не существует, то есть проблема с индексированием - либо вам нужно создать индекс заранее, либо искать исключения по причине его сбоя, как вasticsearch, так и у производителя верблюдов.

Послевы убедитесь, что данные проиндексированы в ES, как и ожидалось, вы можете перейти в kibana-> settings -> index-pattern и добавить шаблон индекса для этого нового шаблона индексов.после этого вы сможете увидеть данные в кибане