python_q4m 0.0.6

Q4M operation wrapper

Downloads ↓

This module is simple Q4M operation wrapper developed by pixiv Inc. for asynchronous upload system

Simple example of usage is followings

>>> from python_q4m.q4m import *
>>> class QueueTable(Q4M):
>>>     def __init__(self, con):
>>>         super(self.__class__, self).__init__(con)
>>>         self.table   = 'queue_table'
>>>         self.columns = ['id',
>>>                         'msg',
>>>                        ]
>>> try:
>>>    con = MySQLdb.connect(host='localhost',
>>>                          db=dbname,
>>>                          user=username,
>>>                          passwd=password,
>>>                         )
>>>    q = QueueTable(con)
>>>    q.enqueue([1, 'msg'])
>>>    while q.wait() == 0:
>>>        time.sleep(1);
>>>     res = q.dequeue()
>>>     print res['id']
>>>     print res['msg']
>>>     q.end()
>>>     con.close()
>>> except MySQLdb.Error, e:
>>>     print 'Error %d: %s' % (e.args[0], e.args[1])
>>>     q.abort()
>>>     con.close()

And it is necessary to create following table for above example.

CREATE TABLE queue_table (id int(11) NOT NULL, msg text NOT NULL) ENGINE=QUEUE;

• Author: Tatsuhiko Kubo (cubicdaiya@gmail.com)
• Home Page: http://github.com/cubicdaiya/python-q4m
• Keywords: q4m,mysql,queue
• License: GPL2
• Categories
  • Development Status :: 5 - Production/Stable
  • Intended Audience :: Developers
  • License :: OSI Approved :: GNU General Public License (GPL)
  • Programming Language :: Python
  • Topic :: Software Development :: Libraries :: Python Modules
• Package Index Owner: cubicdaiya
• DOAP record: python_q4m-0.0.6.xml