mysql - 使用elasticsearch River创建索引

标签 mysql elasticsearch elasticsearch-plugin

我正在尝试从数据库表 - User 中轮询数据并填充到elasticsearch中,我在“index”部分中指定索引名称并给出名称,索引被创建为“jdbc”。因此我只能将其查询为“host/jdbc/_search 这是关于什么的?

这是创建用户索引的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 预先感谢您:)

最佳答案

问题是因为我在 jdbc block 中添加了索引和类型。我在几个例子中看到了这一点。在更改了 json 结构后,我在索引 block 中移动了索引和类型,我得到了河流和用户索引

localhost: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"

}, “指数”: { "索引":"用户", “类型”:“用户”, “批量大小”:500 } }

关于mysql - 使用elasticsearch River创建索引,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32093923/

相关文章:

php - 无法使用带有 PDO::execute() 的 php 插入数据库

Mysql sum 与 group_concat 和连接表

ElasticSearch:过滤深度嵌套的数据

hadoop - 具有各种文档(pdf、ppt、MS word、纯文本等)的 hadoop 可搜索存档的最佳实践

java - 在 Elasticsearch 插件中读取文件

php - 通过单击 anchor 标记将 PHP 变量发送到另一个页面

mysql - 如何多次更新表上的字段,不包括不存在的字段

docker - 如何将elasticsearch模板与docker镜像捆绑在一起?

elasticsearch - 如何使用原因 “empty String”调试 Elasticsearch 错误number_format_exception但没有字段名称

maven - Elasticsearch 6.0.1 NoSuchFieldError : LUCENE_6_0_0