logstash_config.example 1.76 KB
Newer Older
1
input {
2 3 4 5 6
    stdin {
        codec => plain {
            charset => "Windows-1252"
        }
    }
7 8 9
}

filter {
10 11
    csv {
        columns => ["Código Órgão Superior","Nome Órgão Superior","Código Órgão","Nome Órgao","Código Unidade Gestora","Nome Unidade Gestora","Código Função","Nome Função","Código Subfunção","Nome Subfunção","Código Programa","Nome Programa","Código Ação","Nome Ação","Linguagem Cidadã","CPF Favorecido","Nome Favorecido","Número Documento","Gestão Pagamento","Data Pagamento","Valor"]
12
        separator => "	"
13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33
        add_field => { "timestamp" => "%(timestamp)s" }
    }
    mutate {
        convert => { "Código Órgão Superior" => "integer" }
        convert => { "Código Órgão" => "integer" }
        convert => { "Código Unidade Gestora" => "integer" }
        convert => { "Código Grupo Despesa" => "integer" }
        convert => { "Código Elemento Despesa" => "integer" }
        convert => { "Código Função" => "integer" }
        convert => { "Código Subfunção" => "integer" }
        convert => { "Código Programa" => "integer" }
        convert => { "Código Ação" => "integer" }
        convert => { "Código Favorecido" => "integer" }
        convert => { "Gestão Pagamento" => "integer" }
        convert => { "Valor" => "float" }
    }
    date {
        match => [ "timestamp", "dd/MM/YYYY HH:mm:ss", "ISO8601" ]
        target => [ "@timestamp" ]
    }
    date {
34 35
        match => [ "Data Pagamento", "dd/MM/YYYY" ]
        target => [ "Data Pagamento Timestamp" ]
36
    }
37 38 39
}

output {
40 41 42 43 44 45 46 47 48
    elasticsearch {
        action => "index"
        user => "%(user)s"
        password => "%(password)s"
        hosts => "http://%(host)s:9200"
        index => "%(index)s-%(date)s"
        workers => 1
    }
    stdout {}
49
}