Hi all,
I’m currently writing a ms sql to couchbase bulk transfer module. For speed I want to use TxAsync, but somehow it seems I’m missing something It never transfers data, but the error callback is always triggered with “Operation timed out”. What am I doing wrong?
Thx!
Code snippet:
class Stuff(object):
def init(self):
self.cb = TxAsync(host=‘kasspp12’, bucket=‘default’)
d = self.cb.connect()
d.addCallback(self.on_connect_success)
def on_connect_success(self, err):
...
while row:
ar = self.cb.set(key, value)
ar.callback = self.on_set
ar.errback = self.on_error
reactor.run()
...
stuff = Stuff()
reactor.run()