我在 scala 中使用循环每 10 秒查询一次 Oracle 表，因为 Oracle 表不断插入。我创建一个选择请求，然后创建 n json 字符串，其中包含来自 oracle 的 n 行，并将其推送到 Elasticsearch 中。之后，我创建了一个删除请求以删除我插入到 ES 中的 Oracle 表中的 n 行。我开发了一种完全初学者的方法。那么您能否建议我一种更好的方法来将实时或微批量数据从 Oracle 加载到 ES 并从 Oracle 中删除。我听说过logstach 或SreamSets。你有什么主意吗？谢谢
问问题
312 次