Snowflake to Elasticsearch Using Logtsash

ksaimohan2k · August 28, 2023, 8:23am

Thanks @Rios for help

Tried the same as mentioned using the link you shared regarding Logstash TimeZone

Here is the modified config file


input {
  jdbc {
    jdbc_driver_library => "C:\ELKStack\logstash-8.8.1-windows-x86_64\logstash-8.8.1\logstash-core\lib\jars\snowflake-jdbc-3.9.2-javadoc.jar"
    jdbc_driver_class => "com.snowflake.client.jdbc.SnowflakeDriver"
    jdbc_connection_string => "jdbc:snowflake://*******.uae-north.azure.snowflakecomputing.com/?db=SNOWFLAKE_SAMPLE_DATA&warehouse=COMPUTE_WH"
    jdbc_user => "username"
    jdbc_password => "password"
    jdbc_default_timezone => "Asia/Dubai[dst_enabled_on_overlap:true]"
    schedule => "* * * * *"
    statement => "SELECT * FROM TPCH_SF1.CUSTOMER LIMIT 10;"
  }
}
filter
{}
output
{
  elasticsearch
  {
    hosts => ["http://localhost:9200"]
    user => "username"
    password => "password"
    index =>"snowflakelog_index"
  }
}

And executed the conf file using the command

logstash.bat -f C:\ELKStack\logstash-8.8.1-windows-x86_64\logstash-8.8.1\config\conf.d\test.conf --path.settings C:\ELKStack\logstash-8.8.1-windows-x86_64\logstash-8.8.1\config

But still the error remains the same