centralised-logging.txt

= Installing the Centralised Logging Suite
== Installing the Centralised Log Relay/Transformer
Locate a bare metal system that meets the following minimum specifications

* 8GB of Memory
* Single Socket Xeon Class CPU
* 500GB of Disk Space

Do a fresh CentOS 7 basic install onto the machine. The required repositories
are enabled by

    yum install centos-release-opstools

Please note, the repositories for elasticsearch and for kibana need to be
enabled manually from their upstream provider.

Kibana is a web application so it can be used directly to port 5601, or using the apache http server as a proxy. We suggest to use the apache http server as a
proxy to kibana, for several reasons (it is easier to have the port 80 open on the firewalls, the apache http server can be configured to use authentication, a
https can be used...).

First thing we will need to open the firewall on the machine to allow connections to fluentd and apache

 firewall-cmd --zone=public --add-port=4000/tcp --permanent
 firewall-cmd --zone=public --add-service=http --permanent

.To use kibana directly
[NOTE]
firewall-cmd --zone=public --add-port=5601/tcp --permanent


 firewall-cmd --reload

Once that is done, install the fluentd and elasticsearch software with the following commands

 yum install -y elasticsearch fluentd rubygem-fluent-plugin-elasticsearch kibana httpd

Now we will configure elasticsearch. To do this edit the file /etc/elasticsearch/elasticsearch.yml and add the following lines to the end of the file

 http.cors.enabled: true
 http.cors.allow-origin: "/.*/"

Now start the elasticsearch instance and enable it at boot

 systemctl start elasticsearch
 systemctl enable elasticsearch

To confirm the elasticsearch instance is working, run the following curl command and confirm it returns a valid response similar to below

 curl http://localhost:9200/

This should give the response

 {
   "status" : 200,
   "name" : "elasticsearch.example.com",
   "cluster_name" : "elasticsearch",
   "version" : {
     "number" : "1.5.2",
     "build_hash" : "c88f77ffc81301dfa9dfd81ca2232f09588bd512",
     "build_timestamp" : "2015-02-19T13:05:36Z",
     "build_snapshot" : false,
     "lucene_version" : "4.10.3"
   },
   "tagline" : "You Know, for Search"
 }

Once this is done, we now need to configure fluentd to accept log data and write it to elasticsearch. Edit the file /etc/fluentd/fluent.conf and make it have the just the following content

 # In v1 configuration, type and id are @ prefix parameters.
 # @type and @id are recommended. type and id are still available for backward compatibility

 <source>
   @type forward
   port 4000
   bind 0.0.0.0
 </source>

 #This must be placed at the end of the file as it will process everything
 <match **>
   @type elasticsearch
   host localhost
   port 9200
   logstash_format true
   flush_interval 5
 </match>

Now start fluentd and enable it at boot

 systemctl start fluentd
 systemctl enable fluentd

Check the journal for fluentd and ensure it has no errors at start

 journalctl -u fluentd -l -f

.Configure apache http server as a proxy
[NOTE]
===============================
Create the file /etc/httpd/conf.d/kibana.conf and place the following content inside

Listen 80 
<VirtualHost *:80>
  RewriteEngine On
  ProxyRequests Off

  RewriteRule /kibana(.*) http://localhost:5601$1 [P]

  <Location /kibana>
    ProxyPassReverse http://localhost:5601/
  </Location>

</VirtualHost>

Apache http server needs to enable the network connection, start the service and enable it at boot

 setsebool -P httpd_can_network_connect 1
 systemctl start httpd
 systemctl enable httpd

===============================

== Installing the log collection agent on all nodes
To collect the logs from all machines in the OpenStack environment and send
them to your centralised logging server, you will need to make sure the
following channel is enabled in Subscription Manager/Satellite on all machines

 rhel-7-server-openstack-7.0-optools-rpms

Once this is done, you will need to install the following packages on all
OpenStack machines

 yum install -y fluentd rubygem-fluent-plugin-add

Now you will need to configure the fluent user on all nodes so it has
permissions to read all the OpenStack log files. Do this by running the
following command

 for user in {keystone,nova,neutron,cinder,glance,heat,ceilometer,sahara,ironic}; do  usermod -a -G $user fluentd; done

Note that you may get an error on some nodes about missing groups. This is
ok as not all nodes run all services.

Some of the /var/log/{keystone,nova,neutron,cinder,glance,heat,ceilometer,sahara,ironic} directories do not have the proper group so:

 for dir in {keystone,nova,neutron,cinder,glance,heat,ceilometer,sahara,ironic}; do chown $dir:$dir /var/log/$dir; done

Next you will need to configure fluentd on all the machines. Make sure the
file /etc/fluentd/fluent.conf on all machines looks like the following (be
sure to replace $FQDN_OF_LOGGING_SERVER with the dns name or IP of your
centralised logging server configued above)


 # In v1 configuration, type and id are @ prefix parameters.
 # @type and @id are recommended. type and id are still available for backward compatibility
 
 # Nova compute
 <source>
   @type tail
   path /var/log/nova/nova-compute.log
   tag nova.compute
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) \[(?<context>[^\]]*)\] (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match nova.compute>
   type add
   <pair>
     service nova.compute
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Nova API
 <source>
   @type tail
   path /var/log/nova/nova-api.log
   tag nova.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) \[(?<context>[^\]]*)\] (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match nova.api>
   type add
   <pair>
     service nova.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Nova Cert
 <source>
   @type tail
   path /var/log/nova/nova-cert.log
   tag nova.cert
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match nova.cert>
   type add
   <pair>
     service nova.cert
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Nova Conductor
 <source>
   @type tail
   path /var/log/nova/nova-conductor.log
   tag nova.conductor
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match nova.conductor>
   type add
   <pair>
     service nova.conductor
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Nova Consoleauth
 <source>
   @type tail
   path /var/log/nova/nova-consoleauth.log
   tag nova.consoleauth
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match nova.consoleauth>
   type add
   <pair>
     service nova.consoleauth
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Nova Scheduler
 <source>
   @type tail
   path /var/log/nova/nova-scheduler.log
   tag nova.scheduler
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match nova.scheduler>
   type add
   <pair>
     service nova.scheduler
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Neutron Openvswitch Agent
 <source>
   @type tail
   path /var/log/neutron/openvswitch-agent.log
   tag neutron.openvswitch
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match neutron.openvswitch>
   type add
   <pair>
     service neutron.openvswitch
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Neutron Server
 <source>
   @type tail
   path /var/log/neutron/server.log
   tag neutron.server
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match neutron.server>
   type add
   <pair>
     service neutron.server
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Neutron DHCP Agent
 <source>
   @type tail
   path /var/log/neutron/dhcp-agent.log
   tag neutron.dhcp
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match neutron.dhcp>
   type add
   <pair>
     service neutron.dhcp
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Neutron L3 Agent
 <source>
   @type tail
   path /var/log/neutron/l3-agent.log
   tag neutron.l3
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match neutron.l3>
   type add
   <pair>
     service neutron.l3
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Neutron Metadata Agent
 <source>
   @type tail
   path /var/log/neutron/metadata-agent.log
   tag neutron.metadata
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match neutron.metadata>
   type add
   <pair>
     service neutron.metadata
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Keystone
 <source>
   @type tail
   path /var/log/keystone/keystone.log
   tag keystone
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match keystone>
   type add
   <pair>
     service keystone
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Glance API
 <source>
   @type tail
   path /var/log/glance/api.log
   tag glance.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match glance.api>
   type add
   <pair>
     service glance.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Glance Registry
 <source>
   @type tail
   path /var/log/glance/registry.log
   tag glance.registry
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match glance.registry>
   type add
   <pair>
     service glance.registry
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Cinder API
 <source>
   @type tail
   path /var/log/cinder/api.log
   tag cinder.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match cinder.api>
   type add
   <pair>
     service cinder.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Cinder Scheduler
 <source>
   @type tail
   path /var/log/cinder/scheduler.log
   tag cinder.scheduler
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match cinder.scheduler>
   type add
   <pair>
     service cinder.scheduler
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Cinder Volume
 <source>
   @type tail
   path /var/log/cinder/volume.log
   tag cinder.volume
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match cinder.volume>
   type add
   <pair>
     service cinder.volume
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Cinder Backup
 <source>
   @type tail
   path /var/log/cinder/backup.log
   tag cinder.backup
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match cinder.backup>
   type add
   <pair>
     service cinder.backup
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Heat API CloudFormation
 <source>
   @type tail
   path /var/log/heat/heat-api-cfn.log
   tag heat.api.cfn
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match heat.api.cfn>
   type add
   <pair>
     service heat.api.cfn
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 
 # Heat API CloudWatch
 <source>
   @type tail
   path /var/log/heat/heat-api-cloudwatch.log
   tag heat.api.cloudwatch
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match heat.api.cloudwatch>
   type add
   <pair>
     service heat.api.cloudwatch
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Heat API
 <source>
   @type tail
   path /var/log/heat/heat-api.log
   tag heat.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match heat.api>
   type add
   <pair>
     service heat.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Heat Engine
 <source>
   @type tail
   path /var/log/heat/heat-engine.log
   tag heat.engine
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match heat.engine>
   type add
   <pair>
     service heat.engine
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer Agent Notification
 <source>
   @type tail
   path /var/log/ceilometer/agent-notification.log
   tag ceilometer.agent.notification
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.agent.notification>
   type add
   <pair>
     service ceilometer.agent.notification
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer Alarm Evaluator
 <source>
   @type tail
   path /var/log/ceilometer/alarm-evaluator.log
   tag ceilometer.alarm.evaluator
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.alarm.evaluator>
   type add
   <pair>
     service ceilometer.alarm.evaluator
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer Alarm Notifier
 <source>
   @type tail
   path /var/log/ceilometer/alarm-notifier.log
   tag ceilometer.alarm.notifier
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.alarm.notifier>
   type add
   <pair>
     service ceilometer.alarm.notifier
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer API 
 <source>
   @type tail
   path /var/log/ceilometer/api.log
   tag ceilometer.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.api>
   type add
   <pair>
     service ceilometer.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer DB Sync
 <source>
   @type tail
   path /var/log/ceilometer/ceilometer-dbsync.log
   tag ceilometer.dbsync
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.dbsync>
   type add
   <pair>
     service ceilometer.dbsync
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer Central
 <source>
   @type tail
   path /var/log/ceilometer/central.log
   tag ceilometer.central
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.central>
   type add
   <pair>
     service ceilometer.central
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer Collector
 <source>
   @type tail
   path /var/log/ceilometer/collector.log
   tag ceilometer.collector
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.collector>
   type add
   <pair>
     service ceilometer.collector
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ceilometer Compute
 <source>
   @type tail
   path /var/log/ceilometer/compute.log
   tag ceilometer.compute
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ceilometer.compute>
   type add
   <pair>
     service ceilometer.compute
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Sahara All
 <source>
   @type tail
   path /var/log/sahara/sahara-all.log
   tag sahara.all
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match sahara.all>
   type add
   <pair>
     service sahara.all
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Trove API
 <source>
   @type tail
   path /var/log/trove/trove-api.log
   tag trove.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match trove.api>
   type add
   <pair>
     service trove.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Trove Conductor 
 <source>
   @type tail
   path /var/log/trove/trove-conductor.log
   tag trove.conductor
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match trove.conductor>
   type add
   <pair>
     service trove.conductor
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Trove Task Manager
 <source>
   @type tail
   path /var/log/trove/trove-taskmanager.log
   tag trove.taskmanager
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match trove.taskmanager>
   type add
   <pair>
     service trove.taskmanager
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ironic API
 <source>
   @type tail
   path /var/log/ironic/ironic-api.log
   tag ironic.api
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ironic.api>
   type add
   <pair>
     service ironic.api
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 # Ironic Conductor
 <source>
   @type tail
   path /var/log/ironic/ironic-conductor.log
   tag ironic.conductor
   format multiline
   format_firstline /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   format /(?<time>[^ ]* [^ ]*) (?<pid>[^ ]*) (?<loglevel>[^ ]*) (?<class>[^ ]*) (\[(?<context>[^\]]*)\])? (?<message>.*)/
   time_format %F %T.%L
 </source>
 
 <match ironic.conductor>
   type add
   <pair>
     service ironic.conductor
     hostname "#{Socket.gethostname}"
   </pair>
 </match>
 
 <match greped.**>
   @type forward
   heartbeat_type tcp
   <server>
     name $FQDN_OF_LOGGING_SERVER
     host $FQDN_OF_LOGGING_SERVER
     port 4000
   </server>
 </match>

Now that fluentd is configured, we can start the fluentd service and enable it at boot

 systemctl start fluentd
 systemctl enable fluentd

You should be able to now go to kibana running on your centralised logging server and see logs start to populate

 http://$FQDN_OF_LOGGING_SERVER/