Kiln » Kiln Storage Service Read More
Clone URL:  
/ kiln
webtasks.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
import urllib import settings from redis import Redis from workerqueue import queueutils if settings.HOSTED: _port = settings.REDIS_PORT _host = settings.REDIS_HOST _db = settings.REDIS_DB else: from workerqueue.kilnconfig import KilnConfig _conf = KilnConfig() _port = int(_conf.read('Daemon', 'port')) _host = _conf.read('Daemon', 'host') _db = int(_conf.read('Daemon', 'db')) def _redis(): return Redis(host=_host, port=_port, db=_db) def asyncpost(url, data): r = _redis() d = {'url': url, 'data': urllib.urlencode(data)} queueutils.enqueue(r, 'httppost', d) def queue_repo_index(repo): r = _redis() queueutils.enqueue(r, 'updaterepo', {'repo': repo}, 'low') def queue_repo_create(uuid, pingback, site, meta=None, parent=None): r = _redis() data = dict(uuid=uuid, pingback=pingback, site=site) if meta: data['meta'] = meta if parent: data['parent'] = parent queueutils.enqueue(r, 'createrepo', data) def queue_repo_strip(pingback, uuid, parent, rev, meta, url, ixPerson): r = _redis() data = dict(uuid=uuid, parent=parent, pingback=pingback, url=url, ixPerson=ixPerson, meta=meta, rev=rev) queueutils.enqueue(r, 'striprepo', data)