在couchbase python客戶端中缺少flush方法嗎？

Question

我沒有在8091端口的couchbase admin UI中找到存儲桶的flush按鈕。可能是因爲這個http://www.couchbase.com/issues/browse/MB-5351。

然後我看到這How to delete all items in the bucket?所以我想在Python客戶端做刷新。

import sys 
from couchbase import Couchbase 
from couchbase.exceptions import CouchbaseError 
try: 
    client = Couchbase.connect(bucket='production',host='localhost',port=8091) 
except CouchbaseError as e: 
    print " Sorry , we could not create connection to bucket specified , due to " , e 
else : 
    print "Successfully made the connection to bucket " 

這裏的客戶端我沒有找到刷新的方法。我在IDE中嘗試了intellisense。

請指導我通過python客戶端刷新存儲桶。

Answer 1

看來，couchbase python SDK目前不提供flush（）方法。 但由於flush方法是通過couchbase REST API提供的，因此您可以使用它來刷新存儲桶。

參考：Couchbase REST API，API桶 - http://docs.couchbase.com/admin/admin/REST/rest-bucket-intro.html

蟒蛇SDK提供了一個聯繫對象，您可以使用使用REST利用其HTTP_REQUEST方法來執行管理員任務。 源代碼：在管理類（從源）https://github.com/couchbase/couchbase-python-client/blob/master/couchbase/admin.py

描述：

到Couchbase集羣的管理連接。 （源文件）

With this object, you can do things which affect the cluster, such as 
modifying buckets, allocating nodes, or retrieving information about 
the cluster. 

This object should **not** be used to perform Key/Value operations. The 
:class:`couchbase.bucket.Bucket` is used for that. 

Admin.http_request方法說明：

Perform an administrative HTTP request. This request is sent out to 
    the administrative API interface (i.e. the "Management/REST API") 
    of the cluster. 

    See <LINK?> for a list of available comments. 

    Note that this is a fairly low level function. This class will with 
    time contain more and more wrapper methods for common tasks such 
    as bucket creation or node allocation, and this method should 
    mostly be used if a wrapper is not available. 

---

例子：

首先確保沖洗選項爲您激活桶。

我爲示例創建了一個名爲「default」的測試存儲桶，並在存儲桶中創建了2個文檔。

import sys 
from couchbase import Couchbase 
from couchbase.exceptions import CouchbaseError 

#import Admin module 
from couchbase.admin import Admin 


#make an administrative connection using Admin object 
try: 
    admin = Admin(username='Administrator',password='password',host='localhost',port=8091) 
except CouchbaseError as e: 
    print " Sorry , we could not create admin connection , due to " , e 
else : 
    print "Successfully made an admin connection " 


#retrieve bucket information for bucket named "default" 
# "default" is just the name of the bucket I set up for trying this out 
try: 
    htres = admin.http_request("/pools/default/buckets/default") 
except Exception as e: 
    print "ERROR: ", e 
    sys.exit() 


#print the current number of items in the "default" bucket 
# "default" is just the name of the bucket I set up for trying this out 
print "# of items before flush: ", htres.value['basicStats']['itemCount'] 


#flush bucket 
try: 
    #the bucket information request returned the path to the REST flush method for this bucket 
    # the flush method requires a POST request 
    htres = admin.http_request(htres.value['controllers']['flush'],"POST") 
except Exception as e: 
    print "ERROR: ", e 
    sys.exit() 


#re-retrieve bucket information for bucket named "default" 
try: 
    htres = admin.http_request("/pools/default/buckets/default") 
except Exception as e: 
    print "ERROR: ", e 
    sys.exit() 


#print the number of items in the "default" bucket (after flush) 
print "# of items after flush: ", htres.value['basicStats']['itemCount'] 

結果：

Successfully made an admin connection 
# of items before flush: 2 
# of items after flush: 0