arno/isso
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

use SAQueue and clear cache/queue tables on startup

Browse Source
This commit is contained in:
Martin Zimmermann 2014-07-25 18:59:35 +02:00
parent cffe8cea08
commit 2a0898c928
3 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
isso/__init__.py
View File

@ -175,18 +175,19 @@ class Isso(object):
def make_app(conf): def make_app(conf):
dbobj = db.Adapter(conf.get("general", "dbpath"))
if uwsgi is not None: if uwsgi is not None:
cacheobj = cache.uWSGICache(timeout=3600) cacheobj = cache.uWSGICache(timeout=3600)
else: else:
cacheobj = cache.SACache(conf.get("general", "dbpath"), threshold=2048) cacheobj = cache.SACache(conf.get("general", "dbpath"), threshold=2048)
dbobj = db.Adapter(conf.get("general", "dbpath"))
jobs = tasks.Jobs() jobs = tasks.Jobs()
jobs.register("db-purge", dbobj, conf.getint("moderation", "purge-after")) jobs.register("db-purge", dbobj, conf.getint("moderation", "purge-after"))
jobs.register("http-fetch", dbobj) jobs.register("http-fetch", dbobj)
queueobj = queue.Queue(1024) queueobj = queue.SAQueue(conf.get("general", "dbpath"), 1024)
worker = queue.Worker(queueobj, jobs) worker = queue.Worker(queueobj, jobs)
isso = Isso(conf, cacheobj, dbobj) isso = Isso(conf, cacheobj, dbobj)

1
isso/cache/sa.py vendored
View File

@ -71,6 +71,7 @@ class SACache(Base):
Column("time", Float)) Column("time", Float))
self.metadata.create_all(self.engine) self.metadata.create_all(self.engine)
self.engine.execute(self.cache.delete())
def _get(self, ns, key): def _get(self, ns, key):
return get(self.engine.connect(), self.cache, ns + b'-' + key) return get(self.engine.connect(), self.cache, ns + b'-' + key)

1
isso/queue/sa.py
View File

@ -32,6 +32,7 @@ class SAQueue(Queue):
Column("wait", Float)) Column("wait", Float))
self.metadata.create_all(self.engine) self.metadata.create_all(self.engine)
self.engine.execute(self.queue.delete())
def put(self, item): def put(self, item):
with self.engine.begin() as con: with self.engine.begin() as con: