MonQueue¶

MonQueue is a Python library that allows you to use MongoDB as a (FIFO)message queue.

Quick Start¶

Using MonQueue looks a little bit like this…

To install it, just run:

pip install -U monqueue

Create a queue:

>>> from monqueue import MonQueue
>>> queue = MonQueue('testqueue')

Put one message into the queue:

>>> queue.put('it is a message')
>>> queue.put({'name': 'Rex Zhang', 'city': 'Chengdu', 'country': 'China'})
>>> queue.put([1, 2, 3])

Get the queue’s size:

>>> queue.qsize()
3

Peek oldest message info from the queue, just peek, no pop:

>>> queue.peek()
(u'it is a message', datetime.datetime(2015, 1, 11, 7, 3, 57, tzinfo=<bson.tz_util.FixedOffset object at 0x0000000002708630>))

Get one message from queue and remove it:

>>> queue.get()
u'it is a message'
>>> queue.get()
{u'city': u'Chengdu', u'name': u'Rex Zhang', u'country': u'China'}

Check the queue, return True if the queue empty:

>>> queue.qsize()
2
>>> queue.empty()
False

Clear the queue:

>>> queue.clear()
>>> queue.empty()
True