Configuring streamparse in remote Storm cluster -

bit confused in configuring remote cluster in streamparse.streamparse works fine in localhost .but dont no how set cluster,my config.json is:

{     "library": "",     "topology_specs": "topologies/",     "virtualenv_specs": "virtualenvs/",     "envs": {         "prod": {             "user": "nandaraj",             "nimbus": "localhost",             "workers": ["localhost"],             "log": {                 "path": "",                 "max_bytes": 1000000,                 "backup_count": 10,                 "level": "info"             },             "virtualenv_root": "/data/virtualenvs"         }     } } 

first have tried localhost in nimbus , worker , getting error:

[localhost] executing task '_create_or_update_virtualenv'

fatal error: needed prompt connection or sudo password (host: localhost), input ambiguous in parallel mode

aborting. needed prompt connection or sudo password (host: localhost), input ambiguous in parallel mode

fatal error: 1 or more hosts failed while executing task '_create_or_update_virtualenv'

aborting. 1 or more hosts failed while executing task '_create_or_update_virtualenv'

after have tried ip of computer (in place of localhost worker) in same lan , getting same error.

[192.168.61.41] executing task '_create_or_update_virtualenv'

fatal error: needed prompt connection or sudo password (host: 192.168.61.41), input ambiguous in parallel mode

aborting. needed prompt connection or sudo password (host: 192.168.61.41), input ambiguous in parallel mode

fatal error: 1 or more hosts failed while executing task '_create_or_update_virtualenv'

aborting. 1 or more hosts failed while executing task '_create_or_update_virtualenv'

i have installed streamparse in server , localhost same version , lein of same version , jdk7 on both server , localhost.

you can add following in fabfile.py (you have set env)

from fabric.api import env env.use_ssh_config = true env.password = 'server_password'  streamparse.ext.fabric import *