python
from couchbase.cluster import Cluster, ClusterOptions
from couchbase.cluster import PasswordAuthenticator
cluster = Cluster('couchbase://localhost', ClusterOptions(
PasswordAuthenticator('username', 'password')))
bucket = cluster.bucket('my_bucket')
collection = bucket.default_collection()
query = 'SELECT COUNT(*) FROM my_bucket WHERE condition = true'
result = cluster.query(query)
for row in result.rows():
print(row)
python
from couchbase.cluster import Cluster, ClusterOptions
from couchbase.cluster import PasswordAuthenticator
cluster = Cluster('couchbase://localhost', ClusterOptions(
PasswordAuthenticator('username', 'password')))
bucket = cluster.bucket('my_bucket')
collection = bucket.default_collection()
design_doc = {
'views': {
'my_view': {
'map': 'function (doc, meta) { emit(doc.field1, doc.field2); }'
}
}
}
bucket.bucket_manager().design_create('my_design_doc', design_doc)
result = bucket.query('my_design_doc/my_view', limit=10)
for row in result:
print(row.key, row.value)
