Merge "add ceilometer-send-counter"

bin/ceilometer-send-counter

@@ -0,0 +1,89 @@
+#!/usr/bin/env python
+# -*- encoding: utf-8 -*-
+#
+# Copyright © 2012 Julien Danjou
+#
+# Author: Julien Danjou <julien@danjou.info>
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may
+# not use this file except in compliance with the License. You may obtain
+# a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations
+# under the License.
+
+"""Command line tool for creating counter for Ceilometer.
+"""
+
+import logging
+import sys
+
+from ceilometer import counter
+from ceilometer import publish
+from ceilometer.openstack.common import cfg
+from ceilometer.openstack.common import timeutils
+from ceilometer.openstack.common import context
+
+
+cfg.CONF.register_cli_opts([
+    cfg.StrOpt('counter-name',
+               short='n',
+               help='counter name',
+               required=True),
+    cfg.StrOpt('counter-type',
+               short='y',
+               help='counter type (gauge, delta, cumulative)',
+               default='gauge',
+               required=True),
+    cfg.IntOpt('counter-volume',
+               short='l',
+               help='counter volume value',
+               default=1),
+    cfg.StrOpt('counter-resource',
+               short='r',
+               help='counter resource id',
+               required=True),
+    cfg.StrOpt('counter-user',
+               short='u',
+               help='counter user id'),
+    cfg.StrOpt('counter-project',
+               short='p',
+               help='counter project id'),
+    cfg.StrOpt('counter-timestamp',
+               short='i',
+               help='counter timestamp',
+               default=timeutils.utcnow().isoformat()),
+    cfg.StrOpt('counter-metadata',
+               short='m',
+               help='counter metadata'),
+])
+
+cfg.CONF(sys.argv[1:])
+
+# Set up logging to use the console
+console = logging.StreamHandler(sys.stderr)
+console.setLevel(logging.DEBUG)
+formatter = logging.Formatter('%(message)s')
+console.setFormatter(formatter)
+root_logger = logging.getLogger('')
+root_logger.addHandler(console)
+root_logger.setLevel(logging.DEBUG)
+
+publish.publish_counter(context.get_admin_context(),
+                        counter.Counter(name=cfg.CONF.counter_name,
+                                        type=cfg.CONF.counter_type,
+                                        volume=cfg.CONF.counter_volume,
+                                        user_id=cfg.CONF.counter_user,
+                                        project_id=cfg.CONF.counter_project,
+                                        resource_id=cfg.CONF.counter_resource,
+                                        timestamp=cfg.CONF.counter_timestamp,
+                                        resource_metadata=cfg.CONF.counter_metadata
+                                        and eval(cfg.CONF.counter_metadata)),
+                        cfg.CONF.metering_topic,
+                        cfg.CONF.metering_secret,
+                        cfg.CONF.counter_source)