'Create a river'

def create_river(self, river, river_name=None):

    if isinstance(river, River):
        body = river.serialize()
        river_name = river.name
    else:
        body = river
    return self._send_request('PUT', ('/_river/%s/_meta' % river_name), body)
