<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 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)