2015-08-19 2 views
0

Я пытаюсь опросить данные из таблицы базы данных - пользователь и заполнить в elasticsearch, я указываю имя индекса в разделе «index», указывающее имя, индекс создается как «jdbc». Таким образом, я могу только запросить его как «хост/JDBC/_search что это?создание индекса с elasticsearch рекой

Это запрос POST для индекса создания пользователей

http://localhost:9200/_river/users/_meta 

{ 
"type" : 
"jdbc", 

"schedule" : "0 0-59 0-23 ? * *", 

"jdbc" : 
    { 

    "driver":"com.mysql.jdbc.Driver", 

    "url" : "jdbc:mysql://192.168.52.202/test_dev", 

    "user" : "test_user", 

    "password" : "test_pass", 

    "sql" : "select id as _id,first_name,city,email from USERS", 

    "index":"users", 

    "type":"user" 

    } 

} 

elasticsearch-plugin-head

enter image description here

user type Заранее спасибо :)

+0

Вы должны указать имя и тип индекса в реке json, например «index»: «пользователь», «type»: «student». Я не уверен, что понимаю, что остальная часть вопроса была задумана! – eliasah

+0

Я сделал это - проверьте структуру json –

+0

после этого запроса на отправку. Я получил данные своего пользователя под индексом jdbc, чтобы я мог искать только пользователя с хостом/jdbc/_search. (второе изображение) –

ответ

0

Проблема была в том, что я добавил i ndex и введите в блок jdbc. Я увидел, что в нескольких example.After я изменил структуру JSon, я переехал индекс и тип в индексном блоке я получил реки и пользователи индекс

локальный: 9200/_river/my_jdbc_river/_meta - пост

{ "Тип": "JDBC",

"расписание": "0 0-59 0-23 *?",

"JDBC": { "стратегия": "простой",

"driver":"com.mysql.jdbc.Driver", 

"url" : "jdbc:mysql://192.168.52.202/test_dev", 

"user" : "test", 

"password" : "test_pass", 

"sql" : "select id as _id,first_name,city,email from USERS", 

"poll":"2s" 

}, "Индекс": { "Индекс": "пользователи", "Тип": "пользователь", "bulk_size": 500 }}

Смежные вопросы