'bind_addr: address to bind zmq socket on
db_name: name of database to write to (created if doesn\'t exist)
table_name: name of mongodb \'table\' in the db to write to (created if doesn\'t exist)'

def __init__(self, db_name, table_name, bind_addr='tcp://127.0.0.1:5000'):

    self._bind_addr = bind_addr
    self._db_name = db_name
    self._table_name = table_name
    self._conn = pymongo.Connection()
    self._db = self._conn[self._db_name]
    self._table = self._db[self._table_name]
