habitat.parser_daemon

Run the Parser as a daemon connected to CouchDB’s _changes feed.

Classes

ParserDaemon(config[, daemon_name])

ParserDaemon runs persistently, watching CouchDB’s _changes feed

class habitat.parser_daemon.ParserDaemon(config, daemon_name='parserdaemon')

ParserDaemon runs persistently, watching CouchDB’s _changes feed for new unparsed telemetry, parsing it with Parser and storing the result back in the database.

On construction, it will:

• Connect to CouchDB using self.config["couch_uri"] and config["couch_db"].

run()

Start a continuous connection to CouchDB’s _changes feed, watching for new unparsed telemetry.