class ZeroRpcClient(object):
def __init__(self):
- self.c = zerorpc.Client()
+ self.c = zerorpc.Client(heartbeat=None, timeout=120) #heartbeat=None, timeout=120
self.c.connect("tcp://127.0.0.1:4242") # TODO hard coded for now. we'll change this later
self.cmds = {}
if args.get("network") is not None:
nw_list = self._parse_network(args.get("network"))
- pp.pprint('nwlist1: {0}'.format(nw_list))
-
r = self.c.compute_action_start(
args.get("datacenter"),
args.get("name"),
nw_list = list()
if args.get("network") is not None:
nw_list = self._parse_network(args.get("network"))
- logging.info('nwlist: {0}'.format(nw_list))
- r = self.c.compute_profile(
- args.get("datacenter"),
- args.get("name"),
- args.get("image"),
+
+ params = self._create_dict(
network=nw_list,
command=args.get("docker_command"),
input=args.get("input"),
- output=args.get("output")
- )
- pp.pprint(r)
+ output=args.get("output"))
+
+ for output in self.c.compute_profile(
+ args.get("datacenter"),
+ args.get("name"),
+ args.get("image"),
+ params
+ ):
+ print(output + '\n')
+
+ #pp.pprint(r)
+ #print(r)
+
+ def _create_dict(self, **kwargs):
+ return kwargs
def _parse_network(self, network_str):
'''
parser = argparse.ArgumentParser(description='son-emu compute')
parser.add_argument(
"command",
- choices=['start', 'stop', 'list', 'status'],
+ choices=['start', 'stop', 'list', 'status', 'profile'],
help="Action to be executed.")
parser.add_argument(
"--datacenter", "-d", dest="datacenter",