使用带 jdbc 的 logstash 在 elasticsearch 中触发完全导入

Question

我使用带有 jdbc 插件的 logstash 将数据插入弹性搜索。 jdbc 插件定期读取 last_modified 列并插入所有数据，这些数据比最后一个 运行 更新。 （典型的 jdbc-logstasah 处理）

但有时我需要从头开始运行一个完整的索引。

如何触发完全导入（数据库 -> 弹性）。

我目前的方法是关闭 logstash，重置 .logstash_jdbc_last_run - 计数器并再次启动 logstash。这对我来说似乎不太优雅。

是否有不同的方式来触发完全导入？

Answer 1

您只需将 clean_run parameter 添加到您的 jdbc 输入配置中：

input {
  jdbc {
    ...
    clean_run => true
    ...
  }
}

添加 will ignore the state 存储在 .logstash_jdbc_last_run 文件中。