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, **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'¶
-