Ядокеризованный графит и я работаю сэта библиотека получить метрики из топологии Apache Storm. Я получаю данные метрик, но независимо от того, что я делаю, я могу получать данные только в минуту, где мне действительно нужно количество точек в секунду.

Согласноэтот ТАК пост Я установил политику хранения, чтобы получать данные каждую секунду. Я также установил

conf.put("topology.builtin.metrics.bucket.size.secs", 1);

а также

void initMetrics(TopologyContext context) {
    messageCountMetric = new CountMetric();
    context.registerMetric("digest_count", messageCountMetric, 1);
}

в классе, который устанавливает топологию и сам болт, соответственно. Насколько я понимаю, это должно приводить к тому, что показатели будут передаваться каждую секунду. Что мне здесь не хватает? Как я могу получать метрики для отчета каждую секунду?

т / у заранее и счастливых праздников всем!

обновление 1

вот мой файл storage-schemas.conf:

root@cdd13a16103a:/etc/carbon# cat storage-schemas.conf 
# Schema definitions for Whisper files. Entries are scanned in order,
# and first match wins. This file is scanned for changes every 60 seconds.
#
#  [name]
#  pattern = regex
#  retentions = timePerPoint:timeToStore, timePerPoint:timeToStore, ...

# Carbon's internal metrics. This entry should match what is specified in
# CARBON_METRIC_PREFIX and CARBON_METRIC_INTERVAL settings
[carbon]
pattern = ^carbon\.
retentions = 1s:6h,1min:7d,10min:5y


[default_1min_for_1day]
pattern = .*
retentions = 1s:6h,1min:7d,10min:5y


[test]
pattern = ^test.
retentions = 1s:6h,1min:7d,10min:5y

[storm]
pattern = ^storm.
retentions = 1s:6h,1min:7d,10min:5y

Вот моя настройка конфигурации:

Config conf = new Config();
conf.setDebug(false);
conf.put("topology.builtin.metrics.bucket.size.secs", 1);
conf.registerMetricsConsumer(GraphiteMetricsConsumer.class, 4);
conf.put("metrics.reporter.name", "com.verisign.storm.metrics.reporters.graphite.GraphiteReporter");
conf.put("metrics.graphite.host", "127.0.0.1");
conf.put("metrics.graphite.port", "2003");
conf.put("metrics.graphite.prefix", "storm.test");