def create(args):
    """
    Create a river. This command expects to be fed a JSON document on STDIN.
    """
    data = json.load(sys.stdin)
    m = RiverManager(args.hosts)
    m.create(args.name, data)