使用 ElasticSearch JDBC River 从表中获取更改

我正在为 ElasticSearch 配置 JDBC River，但找不到任何好的配置示例。 我已阅读全部pages on 弹性搜索河jdbc GitHub.

我有一个 SQL 查询，需要每 X 秒从所有表列中获取更改。我如何告诉 JDBC River 某些行已更改并且应该重新索引？

在 ES 服务器启动期间获取数据，正在进行轮询，但不会将更改从 DB 获取到 ES。

我的配置：

curl -XPUT 'localhost:9200/_river/itemsi/_meta' -d '{
"type" : "jdbc",
"jdbc" : {
    "driver" : "com.mysql.jdbc.Driver",
    "url" : "jdbc:mysql://mydb.com:3306/dbname",
    "user" : "yyy",
    "password" : "xxx",
    "sql" : "SELECT ii.id AS _id, ii.id AS myid, ... FROM ... LEFT JOIN .. ON...",
    "poll" : "6s",
    "strategy" : "simple"
    },
"index" : {
    "index" : "invoiceitems",
    "bulk_size" : 600,
    "max_bulk_requests" : 10,
    "bulk_timeout" : "5s",
    }
}'

谢谢。

您可以使用 Schedule 参数来重复运行 jdbc River 插件。

计划参数示例：

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

这会在周/月/年的所有日子、每分钟、每小时执行 JDBC River。

有关计划参数的更多详细信息，请阅读文档，https://github.com/jprante/elasticsearch-river-jdbc