小编Kul*_*gar的帖子

我有一个jdbc我的内连接input在logstash哪里,因为我试图根据执行查询schedule性能.我经历了jdbc和rufus-scheduler,但仍然不清楚这五颗星(*)单独代表什么.

据我所知,从左到右的星星(*****):

1. 分钟
2. 小时
3. 从(月)
4. 到(月)
5. 天

因此,如果它是这样的场景(*****),则表示调度程序将每分钟运行一次.因此,如果我每五分钟运行一次,那么调度程序应该如何？像(5****)的东西？

我认为是对的吗？或者如果我错了请纠正我.

错误:

c:\ Program Files\Logstash\bin> logstash.bat -e'input {stdin {}} output {stdout {}}'发生意外错误!:错误=>错误的URI(不是URI？):文件:// c:/ Program Files/Logstash/confi g/log4j2.properties,:backtrace => ["C:/ Program Files/Logstash/vendor/jruby/lib/ruby​​/1.9/uri/common.rb:176:在split'","C:/ Program Files/Logstash/vendor/jruby/lib/ruby​​/1.9/uri/common.rb:210:在解析'","C:/ Program Files/Logstash/vendor/jruby/lib/ruby​​/1.9/uri/common.rb:747:在解析'","C:/ Program Files/Logstash/vendor/jruby/lib/ruby​​/1.9/uri/common.rb:994:inURI'","c:/ Program Files/Logstash/log stash-core/lib/logstash/logging/logger.rb:76:in initialize '","org/jruby/ext/thread/Mutex.java:149:insynchronize'","c:/ Program Files/Logstash/logstash-core/lib/logstash/logging/logger.rb:74:in in itialize' ","c:/ Program Files/Logstash/logstash -core/lib/logstash/runner.rb:193:不执行'","c:/ P rogram Files/Logstash/vendor/bundle/jruby/1.9/gems/clamp-0.6.5/lib/clamp/command.rb:67:在运行'","c:/ Program Files/Logstash/logstash -core/lib/logstash/runner.rb:178:inrun' ","c:/ Program Files/Logst ash/vendor/bundle/jruby/1.9/gems/clamp-0.6.5/lib/clamp/command.rb:132:in run'","c:\ Program Files\\ Logstash\lib\bootstrap\environment.rb:71:in(root)'"]

每次我在Elasticsearch中按照有关创建索引，映射和添加数据的说明进行操作时，都会出现错误。我正在使用邮递员。首先，我创建索引：

POST http://localhost:9200/schools

（实际上，我必须使用put才能成功创建）

接下来，我创建映射并添加数据：

POST http://localhost:9200/schools/_bulk

请求正文

    {
       "index":{
          "_index":"schools", "_type":"school", "_id":"1"
       }
    }
    {
       "name":"Central School", "description":"CBSE Affiliation", "street":"Nagan",
       "city":"paprola", "state":"HP", "zip":"176115", "location":[31.8955385, 76.8380405],
       "fees":2000, "tags":["Senior Secondary", "beautiful campus"], "rating":"3.5"
    }
    {
       "index":{
          "_index":"schools", "_type":"school", "_id":"2"
       }
    }
    {
       "name":"Saint Paul School", "description":"ICSE 
       Afiliation", "street":"Dawarka", "city":"Delhi", "state":"Delhi", "zip":"110075",
       "location":[28.5733056, 77.0122136], "fees":5000,
       "tags":["Good Faculty", "Great Sports"], "rating":"4.5"
    }
    {
       "index":{"_index":"schools", "_type":"school", "_id":"3"}
    }
    {
       "name":"Crescent School", "description":"State Board Affiliation", "street":"Tonk Road", 
       "city":"Jaipur", "state":"RJ", "zip":"176114","location":[26.8535922, 75.7923988],
       "fees":2500, "tags":["Well equipped labs"], …

我第一次只是在nohupUbuntu服务器上玩游戏.我阅读了一些关于nohup运行命令的文档,并了解了运行命令,例如nohup ./server.sh &.

我想知道的是,我应该如何运行JMeter脚本(无头模式)nohup？以下是我需要运行的脚本nohup:

./jmeter.sh -n -t /home/chamith/WSO2MB/new/apache-jmeter-2.13/bin/GamesSubscriber.jmx

当我尝试nohup在脚本中使用正常操作时,总是会抛出一个错误说-n command not found.我该如何继续这个？任何帮助,将不胜感激.

我jdbc在logstash输入插件中有一个MySQL语句.

statement => "SELECT * from TEST where id > :sql_last_value"

我的表没有任何date或datetime字段.所以我试图通过使用a逐个检查来更新索引,scheduler是否已将任何新行添加到表中.

我应该只能更新新记录,而不是更新现有记录的现有值更改.所以要做到这一点,我有这样一个logstash输入:

input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://myhostmachine:3306/mydb" 
        jdbc_user => "root"
        jdbc_password => "root"
        jdbc_validate_connection => true
        jdbc_driver_library => "/mypath/mysql-connector-java-5.1.39-bin.jar"
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        jdbc_paging_enabled => "true"
        jdbc_page_size => "50000"
        schedule => "* * * * *"
        statement => "SELECT * from mytable where id > :sql_last_value"
        use_column_value => true
        tracking_column => id
        last_run_metadata_path => "/path/.logstash_jdbc_last_run"
        clean_run …

我试图根据我在 SO 中看到的示例创建字典（以实现切换器），并想出了这个：

def filter_on_arg(arg):
    switcher = {
        'can': get_can(table_name, filename, arg),
        'aus': get_aus(table_name, filename, arg)
    }
    return switcher.get(arg, "Invalid arg")

但是当我尝试编译和运行脚本时，arg的值为aus；它仍在执行第一个方法get_can，从中我认为上述方法有问题。

我也尝试使用NeoPySwitch库，但是在使用 pip 安装它时遇到了一些问题。

我使用切换器，而不是使用 if/elif；这样基于一个键，我就可以调用上面的函数。

我试图通过从Postman发送GET http调用来获取日期范围和我手动添加的字段（“ log_type”），以获取索引结果，

所以现在当我单独查询它时，我可以获得结果，例如：

日期范围：http：// localhost：9200 / dialog_test / _search？q =时间戳：[2016-08-05 + TO + 2016-08-06]

log_type：http：// localhost：9200 / dialog_test / _search？q = log_type：GetProvisioning％20SUCCESS

在上面的URL（log_type）中，GetProvisioning Success是log_type。

因此，我想知道的是，如何将它们都合并到一个查询中以识别在特定日期范围和特定log_type之间的结果是什么？

任何帮助，不胜感激