mongoqueue
mongoqueue copied to clipboard
kapilt
Simple python library for distributed queues in mongodb
The use of `find_and_modify` means only one Job is recovered from stale lock. The same query + update expressions work with the PyMongo function `update_many` which updates all documents that...
The default timeout is `int: 300` See: https://github.com/kapilt/mongoqueue/blob/master/mongoqueue/mongoqueue.py#L34 It is used to find locked jobs which have expired here: https://github.com/kapilt/mongoqueue/blob/master/mongoqueue/mongoqueue.py#L66 the use of one unnamed parameter to `timedelta` means it...
1. Defined queue = MongoQueue( ... Connection(TEST_DB).doctest_queue, ... consumer_id="consumer-1", ... timeout=300, ... max_attempts=3) 2. Then got job by ----- job = queue.next() 3. Job has error ---- job.error("Error") ------- here...
I updated to work with recent library versions Tests are passing for Travis CI for the following: python: - "2.7" - "3.4" - "3.5" - "3.6" - "3.7-dev" env: -...
It's very slow when pull tasks via next(), finally i find there is no any index. After i added following indexs, it's fast now. collection.ensure_index([('priority', ASCENDING)]) collection.ensure_index([('locked_by', ASCENDING), ('locked_at', ASCENDING),...
This library is in status coding, or is better use another, my project is in python 3 and this library not run the problem is that I use aws lambdas...
``` >>> queue = MongoQueue(Connection('localhost').doctest_queue, consumer_id='consumer-1', timeout=300, max_attempts=3) >>> queue.put({"foobar": 1}) TypeError: 'Collection' object is not callable. If you meant to call the 'insert' method on a 'Database' object it...
Since pymongo.Connection is deprecated, use MongoClient instead.
