123abe5121daef3513ae0635313b60c5b50defe2
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 prometheus(self
, args
):
60 vnf_name
= self
._parse
_vnf
_name
(args
.get("vnf_name"))
61 vnf_interface
= self
._parse
_vnf
_interface
(args
.get("vnf_name"))
62 r
= self
.c
.prometheus(
63 args
.get("datacenter"),
70 def _parse_vnf_name(self
, vnf_name_str
):
71 vnf_name
= vnf_name_str
.split(':')[0]
74 def _parse_vnf_interface(self
, vnf_name_str
):
76 vnf_interface
= vnf_name_str
.split(':')[1]
82 parser
= argparse
.ArgumentParser(description
='son-emu monitor')
85 help="Action to be executed")
87 "--vnf_name", "-vnf", dest
="vnf_name",
88 help="vnf name:interface to be monitored")
90 "--metric", "-m", dest
="metric",
91 help="tx_bytes, rx_bytes, tx_packets, rx_packets")
93 "--cookie", "-c", dest
="cookie",
94 help="flow cookie to monitor")
96 "--query", "-q", dest
="query",
97 help="prometheus query")
99 "--datacenter", "-d", dest
="datacenter",
100 help="Data center where the vnf is deployed")
103 #print "This is the son-emu monitor CLI."
104 #print "Arguments: %s" % str(argv)
105 args
= vars(parser
.parse_args(argv
))
107 c
.execute_command(args
)