pyes.rivers

class pyes.rivers.CouchDBRiver(host='localhost', port=5984, db='mydb', filter=None, filter_params=None, script=None, user=None, password=None, **kwargs)
serialize()
type = 'couchdb'
class pyes.rivers.JDBCRiver(dbhost='localhost', dbport=5432, dbtype='postgresql', dbname=None, dbuser=None, dbpassword=None, poll_time='5s', sql='', name=None, params=None, **kwargs)
type = 'jdbc'
class pyes.rivers.MongoDBRiver(servers, db, collection, index_name, mapping_type, gridfs=False, options=None, bulk_size=1000, filter=None, script=None, **kwargs)
type = 'mongodb'
class pyes.rivers.RabbitMQRiver(host='localhost', port=5672, user='guest', password='guest', vhost='/', queue='es', exchange='es', routing_key='es', exchange_declare=True, exchange_type='direct', exchange_durable=True, queue_declare=True, queue_durable=True, queue_auto_delete=False, queue_bind=True, **kwargs)
type = 'rabbitmq'
class pyes.rivers.River(index_name=None, index_type=None, bulk_size=100, bulk_timeout=None)
serialize()
class pyes.rivers.TwitterRiver(user=None, password=None, **kwargs)
type = 'twitter'