diff options
| author | Julien Danjou <julien@danjou.info> | 2017-09-04 13:47:58 +0200 |
|---|---|---|
| committer | Julien Danjou <julien@danjou.info> | 2017-10-13 18:18:07 +0200 |
| commit | 83ffaffcb2cee6a0b19601bc7cefd863685601e2 (patch) | |
| tree | d28beb0e51bb65ee856ce9dcfd28b63c89371745 /tools | |
| parent | bca9d45ea439220305539f85a653cb31e501be25 (diff) | |
| download | ceilometer-83ffaffcb2cee6a0b19601bc7cefd863685601e2.tar.gz | |
Replace the Gnocchi dispatcher by a publisher
This removes the deprecated Gnocchi dispatcher and replaces it by its
equivalent publisher.
Change-Id: Ie44baf20ccb8de5794f5f0c3d4717f7e56afa63b
Diffstat (limited to 'tools')
| -rwxr-xr-x | tools/migrate_data_to_gnocchi.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/tools/migrate_data_to_gnocchi.py b/tools/migrate_data_to_gnocchi.py index 5e87765f..27c87d97 100755 --- a/tools/migrate_data_to_gnocchi.py +++ b/tools/migrate_data_to_gnocchi.py @@ -37,7 +37,7 @@ from oslo_config import cfg from oslo_db import options as db_options from oslo_log import log -from ceilometer.dispatcher import gnocchi +from ceilometer.publisher import gnocchi from ceilometer import service from ceilometer import storage from ceilometer.storage import impl_mongodb @@ -60,7 +60,7 @@ def get_parser(): parser.add_argument( '--ceilometer-config-file', help="The config file of ceilometer, it is main used for gnocchi " - "dispatcher to init gnocchiclient with the service credentials " + "publisher to init gnocchiclient with the service credentials " "defined in the ceilometer config file. Default as " "/etc/ceilometer/ceilometer.conf", ) @@ -144,7 +144,7 @@ def main(): if args.end_timestamp: time_filters.append({"<": {'timestamp': args.end_timestamp}}) - gnocchi_dispatcher = gnocchi.GnocchiDispatcher(gnocchi_conf) + gnocchi_publisher = gnocchi.GnocchiPublisher(gnocchi_conf, "gnocchi://") batch_size = args.batch_migration_size if total_amount == 'Unknown': @@ -181,7 +181,7 @@ def main(): sample.counter_name, sample.resource_id)) samples_dict = [sample.as_dict() for sample in samples] - gnocchi_dispatcher.record_metering_data(samples_dict) + gnocchi_publisher.publish_samples(samples_dict) length = len(samples) migrated_amount += length if pbar: |