Logstashの順次スレッド実行フロー

Question

私の設定で2つのjdbcセクションを作成しましたが、常に最初のactionAとactionBを実行したいので、それは私のために重要です。これどうやってするの？ここで

は私の設定です：事前に

input { 
    jdbc { 
     type => "actionA" 
     jdbc_validate_connection => true 
     jdbc_connection_string => "jdbc:oracle:thin:@mycomp:1522/db1" 
     ... 
     statement => "SELECT ID FROM my_table WHERE delete='Y'" 
     } 

    jdbc { 
     type => "actionB" 
     jdbc_validate_connection => true 
     jdbc_connection_string => "jdbc:oracle:thin:@mycomp:1522/db1" 
     ... 
     statement => "UPDATE my_table SET delete='T' WHERE delete='Y'" 
     } 
} 
output { 
    stdout { codec => rubydebug } 
    if [type] == "actionA" { 
     elasticsearch { 
      action => "delete" 
      index => "contacts" 
      document_type => "contact" 
      document_id => "%{id}" 
      hosts => ["http://localhost:9200"] 
     } 
    } 
    if [type] == "actionB" { } 


} 

おかげ

ジェイ

Answer 1

あなたはscheduleパラメータを活用し、actionAは常に例えば、actionB前に実行することができますactionAラン毎にさえ分（0、2、4、6、...）とactionBラン毎の奇数分することにより（1、3、5、...）それのためのトリックあり

input { 
    jdbc { 
     type => "actionA" 
     jdbc_validate_connection => true 
     jdbc_connection_string => "jdbc:oracle:thin:@mycomp:1522/db1" 
     ... 
     schedule => "*/2 * * * *" # run every even minutes 
     statement => "SELECT ID FROM my_table WHERE delete='Y'" 
     } 

    jdbc { 
     type => "actionB" 
     jdbc_validate_connection => true 
     jdbc_connection_string => "jdbc:oracle:thin:@mycomp:1522/db1" 
     ... 
     schedule => "1-59/2 * * * *" # run every odd minutes 
     statement => "UPDATE my_table SET delete='T' WHERE delete='Y'" 
     } 
} 

Answer 2

。

ので、各ファイルは、次のようになり、別々のファイルにあなたの行動を置き：

# action_X.conf 
input { 
    jdbc { 
     # ... 
    } 
} 
output { 
    # ... 
} 

次に、ファイルごとに手動でlogstashを実行します。

logstash -f action_a.conf 
logstash -f action_b.conf 

を定期的に繰り返すには、あなたが上記のコマンドを入れることができますシェルスクリプトでこのスクリプトをcrontabに追加します。