jpt-archive/oyster
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

some improvements to the cloud client

Browse Source
This commit is contained in:
James Turk 2012-04-14 00:07:39 -04:00
parent 574d1da843
commit 97e164e6e6
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oyster/ext/cloudsearch.py
View File

@ -21,6 +21,7 @@ class CloudSearch(object):
def flush(self): def flush(self):
print 'flushing!'
if self._current_batch: if self._current_batch:
payload = '[{0}]'.format(','.join(self._current_batch)) payload = '[{0}]'.format(','.join(self._current_batch))
resp = requests.post(self.doc_url, payload, resp = requests.post(self.doc_url, payload,
@ -29,7 +30,7 @@ class CloudSearch(object):
self._current_size = 0 self._current_size = 0
if resp.status_code >= 400: if resp.status_code >= 400:
# http://docs.amazonwebservices.com/cloudsearch/latest/developerguide/DocumentsBatch.html # http://docs.amazonwebservices.com/cloudsearch/latest/developerguide/DocumentsBatch.html
print resp.status_code, resp.text raise Exception('{0}: {1}'.format(resp.status_code, resp.text))
def add_document(self, id, **kwargs): def add_document(self, id, **kwargs):
newdoc = {'type': 'add', 'version': 1, 'lang': 'en', newdoc = {'type': 'add', 'version': 1, 'lang': 'en',