我需要编写一些索引作业,每天运行一次,查询我们的Oracle数据库表并索引到ElasticSearch.由于存在表依赖性,因此有些表首先索引,其他表接下来.但是围绕索引编制过程,我需要增强进入ES索引的字段,以及登录我们的Oracle数据库表作业状态,甚至可能记录索引过程成功/失败的记录.
我可以使用Elastic Search插件JDBC-River吗?
我关心的是在从DB中提取查询后通过insert语句重新登录到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" ] } ] } }'