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?
self.cb = TxAsync(host=‘kasspp12’, bucket=‘default’)
d = self.cb.connect()
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()