Changeset 290
- Timestamp:
- 02/21/08 02:19:10 (9 months ago)
- Files:
-
- 1 modified
-
trunk/tutorial/py/BookmarkExample.py (modified) (9 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/tutorial/py/BookmarkExample.py
r206 r290 22 22 23 23 THRUDOC_BUCKET = "bookmarks"; 24 25 THRUDEX_DOMAIN = "tutorial";26 24 THRUDEX_INDEX = "bookmarks"; 27 25 … … 30 28 chunk = func(THRUDOC_BUCKET, seed, size) 31 29 yield chunk 32 if len(chunk. responses) != size:30 if len(chunk.elements) != size: 33 31 break 34 32 seed = chunk.seed … … 54 52 55 53 transport.open() 54 55 self.thrudex.admin("create_index", THRUDEX_INDEX) 56 56 57 57 def serialize(self, b): … … 82 82 self.add_bookmark(b) 83 83 84 self.thrudex.commitAll()85 86 84 t1 = time() 87 85 … … 100 98 def store_bookmark(self, b): 101 99 b_str = self.serialize(b) 102 bid = self.thrudoc.putValue( b_str)100 bid = self.thrudoc.putValue(THRUDOC_BUCKET, b_str) 103 101 return bid 104 102 105 103 def index_bookmark(self, b_id, b): 106 doc = ThrudexTypes.DocMsg() 107 doc.docid = b_id 108 doc.domain = THRUDEX_DOMAIN 104 doc = ThrudexTypes.Document() 105 doc.key = b_id 109 106 doc.index = THRUDEX_INDEX 110 107 doc.fields = [] 111 108 112 field = ThrudexTypes.Field()113 field. name= "title"109 field = ThrudexTypes.Field() 110 field.key = "title" 114 111 field.value = b.title 115 112 field.sortable = True 116 field.stype = ThrudexTypes.StorageType.UNSTORED117 113 doc.fields.append(field) 118 119 field = ThrudexTypes.Field()120 field. name= "tags"114 115 field = ThrudexTypes.Field() 116 field.key = "tags" 121 117 field.value = b.tags 122 field.stype = ThrudexTypes.StorageType.UNSTORED123 118 doc.fields.append(field) 124 125 self.thrudex.add(doc) 119 self.thrudex.put(doc) 126 120 127 121 def remove_all(self): … … 132 126 docs = [] 133 127 for id in ids.elements: 134 rm = ThrudexTypes.RemoveMsg() 135 rm.domain = THRUDEX_DOMAIN 128 rm = ThrudexTypes.Element() 136 129 rm.index = THRUDEX_INDEX 137 rm. docid= id.key130 rm.key = id.key 138 131 docs.append(rm) 139 132 140 133 self.thrudex.removeList(docs) 141 134 self.thrudoc.removeList(ids.elements) 142 self.thrudex.commitAll() 135 143 136 144 137 t1 = time() … … 147 140 def find(self, terms, random=False, sortby=None): 148 141 print "\nSearching for:", terms 149 #for k,v in options.iteritems():150 #print "\t", k, v142 for k,v in options.iteritems(): 143 print "\t", k, v 151 144 152 145 t0 = time() 153 146 154 q = ThrudexTypes.QueryMsg() 155 q.domain = THRUDEX_DOMAIN 147 q = ThrudexTypes.SearchQuery() 156 148 q.index = THRUDEX_INDEX 157 149 q.query = terms 158 150 159 q.limit = 100151 #q.limit = 100 160 152 #q.offset = 10 161 153 … … 165 157 q.sortby = sortby 166 158 167 ids = self.thrudex. query(q)159 ids = self.thrudex.search(q) 168 160 if ids is None: 169 161 return … … 171 163 print "Found", ids.total, "bookmarks" 172 164 173 if len(ids. ids) > 0:174 bm_strs = self.thrudoc.fetchList( self.create_doc_list(ids. ids))165 if len(ids.elements) > 0: 166 bm_strs = self.thrudoc.fetchList( self.create_doc_list(ids.elements)) 175 167 bms = [self.deserialize(bs) for bs in bm_strs] 176 168 self.print_bookmarks(bms)
