elasticsearch - 尝试使用jdbc River ElasticSearch插件进行批处理

Question

我需要编写一些每天运行一次的索引作业，用于查询 Oracle 数据库表并为 ElasticSearch 建立索引。由于存在表依赖性，一些表首先索引，其他表其次索引。但围绕索引过程，我需要增强进入 ES 索引的字段，以及记录到我们的 Oracle 数据库表作业状态，甚至可能记录索引过程成功/失败的记录。

我可以使用 Elastic Search 插件 JDBC-River吗？

Answer 1

我关心的是在查询后通过插入语句记录回 RDBS 以从数据库中提取。我联系了 jdbc-river 的创建者。他提到这就是我应该如何配置的东西:真的很有帮助!

curl -XDELETE '0:9200/_river/my_jdbc_river/


curl -XPUT '0:9200/_river/my_jdbc_river/_meta' -d '
    {
        "type": "jdbc",
        "jdbc": {
            "url": "jdbc:mysql://localhost:3306/test",
            "user": "",
            "password": "",
            "schedule": "0 0-59 0-23 ? * *",
            "sql": [
                {
                    "statement": "select *, created as _id, \"myjdbc\" as _index, \"mytype\" as _type from orders"
                },
                {
                    "statement": "insert into ack(n,t,c) values(?,?,?)",
                    "parameter": [
                        "$job",
                        "$now",
                        "$count"
                    ]
                }
            ]
        }
    }'