380418f351
* Make number of threads configurable * Improve naming * Update path and log options for Logstash 2.4 * Use the correct logs directory Partially-Implements: blueprint monasca-roles Change-Id: I09388de4d31740f2786393c957201bd037572226
22 lines
636 B
Django/Jinja
22 lines
636 B
Django/Jinja
# Persist transformed logs to Elasticsearch
|
|
|
|
input {
|
|
kafka {
|
|
zk_connect => "{{ monasca_zookeeper_servers }}"
|
|
topic_id => "{{ monasca_transformed_logs_topic }}"
|
|
group_id => "log_persister"
|
|
consumer_id => "log_persister_{{ ansible_hostname }}"
|
|
consumer_threads => "{{ monasca_log_pipeline_threads }}"
|
|
}
|
|
}
|
|
|
|
output {
|
|
elasticsearch {
|
|
index => "monasca-%{[meta][tenantId]}-%{+YYYY.MM.dd}"
|
|
hosts => [{{ monasca_elasticsearch_servers }}]
|
|
document_type => "log"
|
|
template_name => "monasca"
|
|
template => "/etc/logstash/elasticsearch-template.json"
|
|
}
|
|
}
|