0

我根本不知道如何使用这个插件。
我正在运行这个curl：

curl -XPUT 'localhost:9200/_river/faycare_kids/_meta' -d '{
  "jdbc":{
      "driver" : "org.postgresql.Driver",
      "url" : "jdbc:postgresql://localhost:5432/faycare",
      "user" : "faycare",
      "password" : "password",
      "strategy" : "simple",
      "poll" : "5s",
      "scale" : 0,
      "autocommit" : true,
      "fetchsize" : 10,
      "index" : "faycare",
      "type" : "kid",
      "max_rows" : 0,
      "max_retries" : 3,
      "max_retries_wait" : "10s",
      "sql"   : "SELECT kid.id as _id,kid.first_name,kid.last_name FROM kid;"
  }
}'

它返回：

{"ok":true,"_index":"_river","_type":"faycare_kids","_id":"_meta","_version":1}

如何搜索/获取/查看我的数据？

我如何知道是否有任何内容被编入索引？

我尝试了很多东西：

curl -XGET 'localhost:9200/_river/faycare_kids/_search?pretty&q=*'

这给了我关于_river

curl -XGET 'localhost:9200/faycare/kid/_search?pretty&q=*'

这告诉我："error" : "IndexMissingException[[faycare] missing]"

我正在sudo service elasticsearch start后台运行它。

4

4 回答 4

1

一方面，我会安装elasticsearch head，它对于检查集群非常有用。

您可以获得所有索引的统计信息：

curl -XGET 'http://localhost:9200/_all/_status'

您可以检查索引是否存在：

curl -XHEAD 'http://localhost:9200/myindex'

您应该能够像这样搜索所有索引：

  curl -XGET 'localhost:9200/_all/_search?q=*'

如果没有显示，您的河流可能无法正常工作，我会检查您的日志以查看是否出现任何错误。

于 2014-01-07T02:32:07.870 回答
0

我感谢您的所有帮助。elastic-head确实给了我一些见解。显然，JSON当我将我的 JSON 更改为此它时，我的出于某种原因出现了问题：

curl -XPUT 'localhost:9200/_river/my_jdbc_river/_meta' -d '{
      "type" : "jdbc",
      "jdbc" : {
          "driver" : "org.postgresql.Driver",
          "url" : "jdbc:postgresql://localhost:5432/faycare",
          "user" : "faycare",
          "password" : "hatpants",
          "index" : "jdbc",
          "type" : "jdbc"
          "sql"   : "SELECT kid.id as _id,kid.first_name,kid.last_name FROM kid;"
      }
 }'

我不确定具体需要进行哪些更改才能使其正常工作，但它现在可以正常工作。我猜这是jdbc需要添加的外部。我猜我可以改变内部index和type.

于 2014-01-07T12:56:39.433 回答
0

问题在于你设置河流的方式。您指定和索引并键入河流应该在错误的地方批量索引记录。

这样做的正确方法是：

curl -XPUT 'localhost:9200/_river/faycare_kids/_meta' -d '{
  "type" : "jdbc",
  "jdbc":{
      "driver" : "org.postgresql.Driver",
      "url" : "jdbc:postgresql://localhost:5432/faycare",
      "user" : "faycare",
      "password" : "password",
      "strategy" : "simple",
      "poll" : "5s",
      "scale" : 0,
      "autocommit" : true,
      "fetchsize" : 10,
      "max_rows" : 0,
      "max_retries" : 3,
      "max_retries_wait" : "10s",
      "sql"   : "SELECT kid.id as _id,kid.first_name,kid.last_name FROM kid;"
  },
  "index":{
      "index" : "faycare",
      "type" : "kid"
  }
}'
于 2014-01-10T22:55:46.417 回答
-1

我写了一篇关于使用这个插件的快速帖子，希望能给你更多的见解——帖子位于这里。

于 2014-01-07T09:27:36.840 回答