3 (c) 2016 by Manuel Peuster <manuel.peuster@upb.de>
8 from tabulate
import tabulate
13 pp
= pprint
.PrettyPrinter(indent
=4)
15 class ZeroRpcClient(object):
18 self
.c
= zerorpc
.Client()
19 # TODO connect to DCNetwork API
20 #self.c.connect("tcp://127.0.0.1:4242") # TODO hard coded for now. we'll change this later
21 self
.c
.connect("tcp://127.0.0.1:5151")
24 def execute_command(self
, args
):
25 if getattr(self
, args
["command"]) is not None:
26 # call the local method with the same name as the command arg
27 getattr(self
, args
["command"])(args
)
29 print "Command not implemented."
31 def setup_metric(self
, args
):
32 vnf_name
= self
._parse
_vnf
_name
(args
.get("vnf_name"))
33 vnf_interface
= self
._parse
_vnf
_interface
(args
.get("vnf_name"))
34 r
= self
.c
.setup_metric(
40 def stop_metric(self
, args
):
41 vnf_name
= self
._parse
_vnf
_name
(args
.get("vnf_name"))
42 vnf_interface
= self
._parse
_vnf
_interface
(args
.get("vnf_name"))
43 r
= self
.c
.stop_metric(
49 def setup_flow(self
, args
):
50 vnf_name
= self
._parse
_vnf
_name
(args
.get("vnf_name"))
51 vnf_interface
= self
._parse
_vnf
_interface
(args
.get("vnf_name"))
52 r
= self
.c
.setup_flow(
59 def stop_flow(self
, args
):
60 vnf_name
= self
._parse
_vnf
_name
(args
.get("vnf_name"))
61 vnf_interface
= self
._parse
_vnf
_interface
(args
.get("vnf_name"))
69 def prometheus(self
, args
):
70 vnf_name
= self
._parse
_vnf
_name
(args
.get("vnf_name"))
71 vnf_interface
= self
._parse
_vnf
_interface
(args
.get("vnf_name"))
72 r
= self
.c
.prometheus(
73 args
.get("datacenter"),
80 def _parse_vnf_name(self
, vnf_name_str
):
81 vnf_name
= vnf_name_str
.split(':')[0]
84 def _parse_vnf_interface(self
, vnf_name_str
):
86 vnf_interface
= vnf_name_str
.split(':')[1]
92 parser
= argparse
.ArgumentParser(description
='son-emu monitor')
95 choices
=['setup_metric', 'stop_metric', 'setup_flow', 'stop_flow','prometheus'],
96 help="setup/stop a metric/flow to be monitored or Prometheus query")
98 "--vnf_name", "-vnf", dest
="vnf_name",
99 help="vnf name:interface to be monitored")
101 "--metric", "-m", dest
="metric",
102 help="tx_bytes, rx_bytes, tx_packets, rx_packets")
104 "--cookie", "-c", dest
="cookie",
105 help="flow cookie to monitor")
107 "--query", "-q", dest
="query",
108 help="prometheus query")
110 "--datacenter", "-d", dest
="datacenter",
111 help="Data center where the vnf is deployed")
114 #print "This is the son-emu monitor CLI."
115 #print "Arguments: %s" % str(argv)
116 args
= vars(parser
.parse_args(argv
))
118 c
.execute_command(args
)