Logstash定时JDBC输入任务遇连接异常时如何手动触发？

当遇到JDBC或Elasticsearch连接故障导致定时任务未正常执行时，可以通过以下几种方式手动触发任务运行：

方法一：临时修改配置文件执行 #

• 打开你的Logstash配置文件，注释掉JDBC输入块中的schedule配置项：

  # schedule => "0 3 * * * America/New_York"
  

• 启动Logstash并加载修改后的配置：

  # Linux/macOS
  bin/logstash -f /path/to/your/config.conf
  
  # Windows
  bin\logstash.bat -f C:\path\to\your\config.conf
  

• 观察stdout输出确认任务执行完成后，停止Logstash进程，恢复schedule配置项，再重启Logstash回到定时运行模式。

方法二：命令行临时覆盖配置（无需修改原文件） #

直接通过命令行传入临时配置，省略schedule参数让任务立即执行，避免修改原配置文件：

# Linux/macOS
bin/logstash --config.string '
input {
    jdbc {
        jdbc_connection_string => "XXX"
        jdbc_user => "XXX"
        jdbc_password => "XXX"
        jdbc_validate_connection => true
        jdbc_driver_library => "XXX"
        jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
        statement => "XXX"
        type => "XXX"
        add_field => { "[@metadata][indexname]" => "XXX" }
    }
}
output {
    elasticsearch {
        hosts=> ["XXX","XXX","XXX"]
        index=>"%{[@metadata][indexname]}"
        user => XXX
        password => XXX
        ssl => true
        ssl_certificate_verification => false
        cacert => "XXX"
        document_id => "%{uniqueid}"
    }
    stdout {}
}'

# Windows
bin\logstash.bat --config.string "
input {
    jdbc {
        jdbc_connection_string => \"XXX\"
        jdbc_user => \"XXX\"
        jdbc_password => \"XXX\"
        jdbc_validate_connection => true
        jdbc_driver_library => \"XXX\"
        jdbc_driver_class => \"com.microsoft.sqlserver.jdbc.SQLServerDriver\"
        statement => \"XXX\"
        type => \"XXX\"
        add_field => { \"[@metadata][indexname]\" => \"XXX\" }
    }
}
output {
    elasticsearch {
        hosts=> [\"XXX\",\"XXX\",\"XXX\"]
        index=>\"%{[@metadata][indexname]}\"
        user => XXX
        password => XXX
        ssl => true
        ssl_certificate_verification => false
        cacert => \"XXX\"
        document_id => \"%{uniqueid}\"
    }
    stdout {}
}"

任务执行完成后，手动停止该临时Logstash进程即可。

注意事项 #

• 由于你的配置中指定了document_id => "%{uniqueid}"，重复执行任务时Elasticsearch会自动覆盖相同ID的文档，不会产生数据重复，但需确保SQL查询语句的逻辑符合预期（比如是否为增量拉取）。
• 生产环境中执行手动触发前，建议先验证配置的正确性，避免影响正常业务。

内容的提问来源于stack exchange，提问作者Jason