binux /
pyspider
| @@ 111-117 (lines=7) @@ | ||
| 108 | return self.es.update(index=self.index, doc_type=self.__type__, id='%s:%s' % (project, taskid), |
|
| 109 | body={"doc": self._stringify(obj)}, ignore=404) |
|
| 110 | ||
| 111 | def drop(self, project): |
|
| 112 | self.refresh() |
|
| 113 | for record in elasticsearch.helpers.scan(self.es, index=self.index, doc_type=self.__type__, |
|
| 114 | query={'query': {'term': {'project': project}}}, |
|
| 115 | _source=False): |
|
| 116 | self.es.delete(index=self.index, doc_type=self.__type__, id=record['_id']) |
|
| 117 | self.refresh() |
|
| 118 | ||
| 119 | def refresh(self): |
|
| 120 | """ |
|
| @@ 80-85 (lines=6) @@ | ||
| 77 | _source_include=fields or [], ignore=404) |
|
| 78 | return ret.get('_source', None) |
|
| 79 | ||
| 80 | def drop(self, project): |
|
| 81 | self.refresh() |
|
| 82 | for record in elasticsearch.helpers.scan(self.es, index=self.index, doc_type=self.__type__, |
|
| 83 | query={'query': {'term': {'project': project}}}, |
|
| 84 | _source=False): |
|
| 85 | self.es.delete(index=self.index, doc_type=self.__type__, id=record['_id']) |
|
| 86 | ||
| 87 | def refresh(self): |
|
| 88 | """ |
|
