Change in vdsm[master]: contrib: Simple jsonrpc client

Friday, 14 November 2014

Nir Soffer has uploaded a new change for review.

Change subject: contrib: Simple jsonrpc client
......................................................................

contrib: Simple jsonrpc client

This is a simple jsonrpc client for communicating with the jsonrpc
server from the command line.

Arguments

  method  one of the mehtods described in json schema
  params  optionl json object with message parameters

Examples

  Calling method without arguements:

  # jsonrpc Host.getVMList
  {
      "jsonrpc": "2.0",
      "id": "0e043d83-294a-4d31-b1b6-6dc2f2747494",
      "result": [
          "b3f6fa00-b315-4ad4-8108-f73da817b5c5"
      ]
  }

  Calling method with arguements:

  # jsonrpc VM.getStats '{"vmID":
"b3f6fa00-b315-4ad4-8108-f73da817b5c5"}'
  {
      "jsonrpc": "2.0",
      "id": "cefd25a3-6250-4123-8a56-d7047899e19e",
      "result": [
          {
              "status": "Down",
              "exitMessage": "Admin shut down from the engine",
              "vmId": "b3f6fa00-b315-4ad4-8108-f73da817b5c5",
              "exitReason": 6,
              "timeOffset": "0",
              "exitCode": 0
          }
      ]
  }

Requires stomp.py library:
https://pypi.python.org/pypi/stomp.py

Change-Id: Ia6273eabf6f3601602659d1e4e748d8025ae8084
Signed-off-by: Nir Soffer <nsoffer(a)redhat.com&gt;
---
A contrib/jsonrpc
1 file changed, 104 insertions(+), 0 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/vdsm refs/changes/81/35181/1

diff --git a/contrib/jsonrpc b/contrib/jsonrpc
new file mode 100755
index 0000000..3080193
--- /dev/null
+++ b/contrib/jsonrpc
@@ -0,0 +1,104 @@
+#!/usr/bin/python
+#
+# Copyright 2014 Red Hat, Inc.
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
+#
+# Refer to the README and COPYING files for full details of the license
+#
+"""
+jsonrpc-cli - Vdsm jsonrpc client
+"""
+
+import json
+import os
+import signal
+import sys
+import time
+import uuid
+import optparse
+
+import stomp
+
+# Copied from lib/vdsm/vdscli.py
+PKIDIR = '/etc/pki/vdsm'
+KEYFILE = os.path.join(PKIDIR, 'keys/vdsmkey.pem')
+CERTFILE = os.path.join(PKIDIR, 'certs/vdsmcert.pem')
+CACERT = os.path.join(PKIDIR, 'certs/cacert.pem')
+
+PORT = 54321
+DESTINATION = "/queue/_local/vdsm/requests"
+
+
+class Listener(stomp.ConnectionListener):
+
+    def on_error(self, headers, message):
+        print 'Error: %s' % message
+        terminate()
+
+    def on_message(self, headers, message):
+        msg = json.loads(message)
+        print json.dumps(msg, indent=4)
+        terminate()
+
+
+def main(args):
+    parser = option_parser()
+    options, args = parser.parse_args(args)
+    if not args:
+        parser.error("method required")
+
+    msg = {
+        "id": str(uuid.uuid4()),
+        "jsonrpc": "2.0",
+        "method": args[0]
+    }
+
+    if len(args) > 1:
+        msg["params"] = json.loads(args[1])
+
+    conn = stomp.Connection10(
+        host_and_ports=((options.host, PORT),),
+        use_ssl=True,
+        ssl_key_file=KEYFILE,
+        ssl_cert_file=CERTFILE,
+        ssl_ca_certs=CACERT)
+
+    conn.set_listener("", Listener())
+    conn.start()
+    conn.send(body=json.dumps(msg), destination=DESTINATION)
+
+    try:
+        signal.pause()
+    except KeyboardInterrupt:
+        pass
+
+    conn.disconnect()
+
+
+def option_parser():
+    parser = optparse.OptionParser(usage='%prog [options] method [params]')
+    parser.add_option("-a", "--host", dest="host",
+                      help="host address (default localhost)")
+    parser.set_defaults(host="localhost")
+    return parser
+
+
+def terminate():
+    os.kill(os.getpid(), signal.SIGINT)
+
+
+if __name__ == "__main__":
+    main(sys.argv[1:])


-- 
To view, visit http://gerrit.ovirt.org/35181
To unsubscribe, visit http://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: Ia6273eabf6f3601602659d1e4e748d8025ae8084
Gerrit-PatchSet: 1
Gerrit-Project: vdsm
Gerrit-Branch: master
Gerrit-Owner: Nir Soffer <nsoffer(a)redhat.com&gt;

    

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011