pyes.rivers
-
class pyes.rivers.CouchDBRiver(host='localhost', port=5984, db='mydb', filter=None, **kwargs)
-
serialize()
-
class pyes.rivers.RabbitMQRiver(host='localhost', port=5672, user='guest', password='guest', vhost='/', queue='es', exchange='es', routing_key='es', **kwargs)
-
serialize()
-
class pyes.rivers.River(index_name=None, index_type=None, bulk_size=100, bulk_timeout=None)
-
q
-
to_json()