kibana に index登録

PUT /index
{
 "mappings": {
  "doc": {
   "properties": {
    "id": {"type": "integer"},
    "count": {"type": "integer"}
   }
  }
 }
}


GET /_cat/indices?v

$ grep -rF 'pipeline.workers' config/logstash.yml
# pipeline.workers: 2
pipeline.workers: 1

• csv_pipeline.conf

input {
    file {
        path => "/path/..."
        start_position => "beginning"
        sincedb_path => "/dev/null"
    }
}
# The filter part of this file is commented out to indicate that it is
# optional.
filter {
    csv {
        separator => ","
        remove_field => [ "path", "message", "host", "@timestamp", "@version" ]
        columns =>
    }
}
output {
    elasticsearch {
        hosts => [ "localhost:9200" ]
        index => "index"
    }
}