现在我已经让 Logstash 使用 JDBC 插件导入我的 MSSQL 数据库的微型版本。我已将每个 JDBC 输入安排为每分钟运行一次以更新 Elasticsearch。要更新,我目前只是重新导入数据库中的每个表和行,并将所有行添加到 Elasticsearch。但是,当我开始使用完整数据库时,这将非常低效,因为遍历整个数据库需要一分钟多的时间。还有其他方法可以让 Elasticsearch 与我的数据库保持同步吗?我尝试使用 'sql_last_value' 参数仅将新行导入数据库,但这仅在我的数据库表的 'id' 为数字且表中的每个新条目的数字大于最后。数据库中的某些表有一个“id” 它可以是完全随机的(即“43f4-f43ef-e44454r”),不能与“sql_last_value”一起使用,因为它们无法比较。我也根本无法修改实际的数据库,这减少了我很多潜在的解决方案。我觉得好像我在这里没有选择,所以任何人都可以建议我可以尝试的任何东西吗?