Logstash-supported-outputs

Logstash-サポートされる出力

Logstashは、さまざまなデータストアまたは検索エンジンをサポートする複数のプラグインを提供します。 ログの出力イベントは、出力ファイル、標準出力、またはElasticsearchなどの検索エンジンに送信できます。 Logstashでサポートされている出力には3つのタイプがあります。

• 標準出力
• ファイル出力
• ヌル出力

次に、これらのそれぞれについて詳しく説明します。

標準出力（stdout）

フィルターされたログイベントをコマンドラインインターフェイスへのデータストリームとして生成するために使用されます。 次に、データベーストランザクションの合計期間をstdoutに生成する例を示します。

logstash.conf

この構成ファイルには、合計sql_durationを標準出力に書き込むためのstdout出力プラグインが含まれています。

input {
   file {
      path => "C:/tpwork/logstash/bin/log/input.log"
   }
}
filter {
   grok {
      match => [
         "message", "%{LOGLEVEL:loglevel} - %{NOTSPACE:taskid}
            - %{NOTSPACE:logger} - %{WORD:label}( - %{INT:duration:int})?"
      ]
   }
   if [logger] == "TRANSACTION_START" {
      aggregate {
         task_id => "%{taskid}"
         code => "map['sql_duration'] = 0"
         map_action => "create"
      }
   }
   if [logger] == "SQL" {
      aggregate {
         task_id => "%{taskid}"
         code => "map['sql_duration'] ||= 0 ;
            map['sql_duration'] += event.get('duration')"
      }
   }
   if [logger] == "TRANSACTION_END" {
      aggregate {
         task_id => "%{taskid}"
         code => "event.set('sql_duration', map['sql_duration'])"
         end_of_task => true
         timeout => 120
      }
   }
}
output {
   if [logger] == "TRANSACTION_END" {
      stdout {
         codec => line{format => "%{sql_duration}"}
      }
   }
}

注-まだインストールされていない場合は、集約フィルターをインストールしてください。

>logstash-plugin install Logstash-filter-aggregate

Logstashを実行する

次のコマンドを使用してLogstashを実行できます。

>logstash –f logsatsh.conf

Input.log

次のコードブロックは、入力ログデータを示しています。

INFO - 48566 - TRANSACTION_START - start
INFO - 48566 - SQL - transaction1 - 320
INFO - 48566 - SQL - transaction1 - 200
INFO - 48566 - TRANSACTION_END – end

*stdout* （WindowsのコマンドプロンプトまたはUNIXのターミナルになります）

これは、合計sql_duration 320 + 200 = 520です。

520

ファイル出力

Logstashは、フィルターログイベントを出力ファイルに保存することもできます。 上記の例を使用して、出力をSTDOUTではなくファイルに保存します。

logstash.conf

このLogstash構成ファイルは、合計sql_durationを出力ログファイルに保存するようLogstashに指示します。

input {
   file {
      path => "C:/tpwork/logstash/bin/log/input1.log"
   }
}
filter {
   grok {
      match => [
         "message", "%{LOGLEVEL:loglevel} - %{NOTSPACE:taskid} -
            %{NOTSPACE:logger} - %{WORD:label}( - %{INT:duration:int})?"
      ]
   }
   if [logger] == "TRANSACTION_START" {
      aggregate {
         task_id => "%{taskid}"
         code => "map['sql_duration'] = 0"
         map_action => "create"
      }
   }
   if [logger] == "SQL" {
      aggregate {
         task_id => "%{taskid}"
         code => "map['sql_duration'] ||= 0 ;
            map['sql_duration'] += event.get('duration')"
      }
   }
   if [logger] == "TRANSACTION_END" {
      aggregate {
         task_id => "%{taskid}"
         code => "event.set('sql_duration', map['sql_duration'])"
         end_of_task => true
         timeout => 120
      }
   }
}
output {
   if [logger] == "TRANSACTION_END" {
      file {
         path => "C:/tpwork/logstash/bin/log/output.log"
         codec => line{format => "%{sql_duration}"}
      }
   }
}

logstashを実行する

次のコマンドを使用してLogstashを実行できます。

>logstash –f logsatsh.conf

input.log

次のコードブロックは、入力ログデータを示しています。

INFO - 48566 - TRANSACTION_START - start
INFO - 48566 - SQL - transaction1 - 320
INFO - 48566 - SQL - transaction1 - 200
INFO - 48566 - TRANSACTION_END – end

output.log

次のコードブロックは、出力ログデータを示しています。

520

ヌル出力

これは、入力およびフィルタープラグインのパフォーマンスを分析するために使用される特別な出力プラグインです。