169 lines
5.6 KiB
Puppet
169 lines
5.6 KiB
Puppet
notice('MODULAR: fuel-plugin-telemetry: configure.pp')
|
|
|
|
# Let's use already defined params for ceilometer
|
|
include ::ceilometer::params
|
|
|
|
$plugin_data = hiera_hash('telemetry', undef)
|
|
$resource_api = $plugin_data['resource_api']
|
|
$event_api = $plugin_data['event_api']
|
|
|
|
# TODO_0 'set' default values when looking for via hiera
|
|
# TODO_1 add if statments in case of 'advanced settings' passed through Fuel UI
|
|
# TODO_2 checks if we can reach ES, influxdb before actioning?
|
|
# Still needed $aodh_nodes ?
|
|
$aodh_nodes = hiera('aodh_nodes')
|
|
|
|
# TODO_3 es_node should be configured because of a bug in Ceilometer API
|
|
if hiera('lma::collector::elasticsearch::server', false) {
|
|
$elasticsearch_node = hiera('lma::collector::elasticsearch::server')
|
|
$elasticsearch_port = hiera('lma::collector::elasticsearch::rest_port')
|
|
} else {
|
|
$elasticsearch_node = '0.0.0.0'
|
|
$elasticsearch_port = '9200'
|
|
}
|
|
|
|
$ceilometer_service_name = $::ceilometer::params::api_service_name
|
|
# TODO move to hiera
|
|
$event_pipeline_file = '/etc/ceilometer/event_pipeline.yaml'
|
|
# TODO move to hiera
|
|
$ceilometer_publishers = 'direct'
|
|
|
|
$influxdb_address = hiera('telemetry::influxdb::address')
|
|
$influxdb_port = hiera('telemetry::influxdb::port')
|
|
$influxdb_database = hiera('telemetry::influxdb::database')
|
|
$influx_user = hiera('telemetry::influxdb::user')
|
|
$influx_password = hiera('telemetry::influxdb::password')
|
|
|
|
$metering_connection = "stacklight://${influx_user}:${influx_password}@${influxdb_address}:${influxdb_port}/${influxdb_database}"
|
|
|
|
$resource_connection = "es://${elasticsearch_node}:${elasticsearch_port}"
|
|
$event_connection = "es://${elasticsearch_node}:${elasticsearch_port}"
|
|
$connection = $metering_connection
|
|
|
|
$packages = {
|
|
'ceilometer-collector' => {
|
|
# keep 'absent' instead of 'purged' for idempotence
|
|
ensure => 'absent',
|
|
require => Service['ceilometer-collector'],
|
|
},
|
|
'python-pip' => {
|
|
ensure => 'present',
|
|
},
|
|
'influxdb' => {
|
|
ensure => 'present',
|
|
provider => 'pip',
|
|
require => Package['python-pip'],
|
|
# Not sure at a momment
|
|
notify => Service['ceilometer-service']
|
|
},
|
|
'elasticsearch' => {
|
|
ensure => 'present',
|
|
provider => 'pip',
|
|
require => Package['python-pip'],
|
|
# Not sure at a momment
|
|
notify => Service['ceilometer-service']
|
|
},
|
|
}
|
|
|
|
# TODO FOR V3: stop collector only when qeue is empty*
|
|
# *wait utill all the events went from collector
|
|
# before stop collector service
|
|
# maybe service'collector' ensure stopped; require exec 'wait for qeue is empty'
|
|
|
|
create_resources(package, $packages)
|
|
|
|
# Stop not needed any more service
|
|
service { 'ceilometer-collector':
|
|
ensure => stopped,
|
|
enable => false,
|
|
hasstatus => true,
|
|
}
|
|
|
|
# Kafka integration
|
|
|
|
if hiera('telemetry::kafka::enabled') {
|
|
|
|
ceilometer_config { 'oslo_messaging_kafka/consumer_group': value => 'ceilometer' }
|
|
|
|
$kafka_ips = hiera('telemetry::kafka::broker_list')
|
|
$kafka_url = "moskafka://${kafka_ips}"
|
|
$rabbit_url = hiera('telemetry::rabbit::url')
|
|
|
|
ceilometer_config { 'DEFAULT/transport_url': value => $kafka_url }
|
|
ceilometer_config { 'notification/messaging_urls': value => [$kafka_url,$rabbit_url] }
|
|
ceilometer_config { 'oslo_messaging_notifications/transport_url': value => $kafka_url }
|
|
|
|
ceilometer_config { 'compute/resource_update_interval': value => 600 }
|
|
|
|
# Coordination
|
|
$zookeeper_list = hiera('telemetry::kafka::zookeeper_list')
|
|
$zookeeper_url = "zookeeper://${zookeeper_list}"
|
|
ceilometer_config { 'coordination/backend_url': value => $zookeeper_url }
|
|
aodh_config { 'coordination/backend_url': value => $zookeeper_url }
|
|
|
|
}
|
|
|
|
# TODO validate values before proceed
|
|
|
|
ceilometer_config { 'database/metering_connection': value => $metering_connection }
|
|
if $resource_api {
|
|
ceilometer_config { 'database/resource_connection': value => $resource_connection }
|
|
}
|
|
else {
|
|
ceilometer_config { 'database/resource_connection': value => 'es://localhost:9200' }
|
|
}
|
|
if $event_api {
|
|
ceilometer_config { 'notification/store_events': value => True }
|
|
ceilometer_config { 'database/event_connection': value => $event_connection }
|
|
}
|
|
else {
|
|
ceilometer_config { 'notification/store_events': value => false }
|
|
ceilometer_config { 'database/event_connection': value => 'log://' }
|
|
}
|
|
ceilometer_config { 'notification/workers': value => max($::processorcount/3,1) }
|
|
|
|
# Workaround for fixing Ceilometer bug in MOS9.0
|
|
if hiera('fuel_version') == '9.0' {
|
|
file { '/usr/lib/python2.7/dist-packages/ceilometer/event/storage/impl_elasticsearch.py':
|
|
ensure => 'present',
|
|
content => file( 'telemetry/ceilometer_fixes/impl_elasticsearch.py' ),
|
|
mode => '0644',
|
|
owner => 'root',
|
|
group => 'root',
|
|
notify => Service['ceilometer-service','ceilometer-agent-notification'],
|
|
require => File['impl_elasticsearch.pyc'],
|
|
}
|
|
|
|
file {'/usr/lib/python2.7/dist-packages/ceilometer/event/storage/impl_elasticsearch.pyc':
|
|
ensure => 'absent',
|
|
alias => 'impl_elasticsearch.pyc',
|
|
}
|
|
|
|
service {'ceilometer-agent-notification':
|
|
ensure => $service_ensure,
|
|
name => $::ceilometer::params::agent_notification_service_name,
|
|
enable => $enabled,
|
|
hasstatus => true,
|
|
hasrestart => true,
|
|
tag => 'ceilometer-agent-notification',
|
|
}
|
|
|
|
}
|
|
|
|
service { 'ceilometer-service':
|
|
ensure => $service_ensure,
|
|
name => $::ceilometer::params::api_service_name,
|
|
enable => $enabled,
|
|
hasstatus => true,
|
|
hasrestart => true,
|
|
tag => 'ceilometer-service',
|
|
}
|
|
|
|
Ceilometer_config<||> ~> Service['ceilometer-service']
|
|
|
|
class { 'telemetry':
|
|
event_pipeline_file => $event_pipeline_file,
|
|
publishers => $ceilometer_publishers,
|
|
}
|
|
|