I'm not really sure which community to turn to for help, but as I started down this road from information on this forum, this is where I'll start.
I've been trying to follow Thomas Wiecki's presentation on using starcluster, zipline, and Ipython in the cloud for parameter optimization. However, when I try and instantiate the Client() object the process hangs.
Keep in mind, I'm no expert with any of this. And I apologize if this is not exactly the correct form to post in, but as I ran into this trying to optimize for quantopian, I imagine others might as well.
I was able to follow the presentation up until attempting to use the EC2 ami Thomas suggest in his talk. Figuring that I was unable to find it because I was in the wrong region or something I decided to configure my own. So I now have a new ami (ami-3c1b830c) in the us-west-2b availability zone (which is public if it should turn out to be useful to anyone).
I installed/upgraded to: Ipython (1.1.0), pyzmq (14.0.0), zipline (0.5.10)
getting the cluster up and running seems to work without issue.
>>> IPCluster has been started on SecurityGroup:@sc-zipcluster for user 'clusteruser'
with 2 engines on 2 nodes.
To connect to cluster from your local machine use:
from IPython.parallel import Client
client = Client('/Users/clusteruser/.starcluster/ipcluster/SecurityGroup:@sc-zipcluster-us-west-2a.json', sshkey='/Users/clusteruser/.ssh/starclusterKey.rsa')
When I look at the generated json file for configuring the ipcluster it looks like this...
{
"control": 45326,
"task": 58177,
"notification": 35696,
"task_scheme": "leastload",
"mux": 44860,
"iopub": 35537,
"ssh": "[email protected]",
"key": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
"registration": 34502,
"interface": "tcp://xxx.xx.xx.xx",
"signature_scheme": "hmac-sha256",
"pack": "json",
"unpack": "json",
"location": "xxx.xx.xx.xx"
}
HERE's the problem:
When I try and connect to the ipcluster as indicated in various on-line examples the session hangs, and never returns, when trying to instantiate the Client().
from IPython.parallel import Client
client = Client('/Users/clusteruser/.starcluster/ipcluster/SecurityGroup:@sc-zipcluster-us-west-2a.json', sshkey='/Users/clusteruser/.ssh/starclusterKey.rsa')
When I just use IPython.parallel locally, simply calling Client() with no parameters it works without issue.
I'm not really sure where to begin to troubleshoot. Any advise from people that have gone down this road would really be of great help.