Closed amunra closed 8 months ago
Sender.from_conf
Sender.from_env
at=
.row()
.dataframe()
c-questdb-client
at=..
row
dataframe
at=None
Sender::from_conf('...', **kwargs)
with sender.transaction()
sender.flush(buffer, transactional=True)
with sender:
sender.transaction()
init_buf_size
max_buf_size
_FLUSH_FMT
from_conf
txn.commit()
sender.flush()
txn
Closes https://github.com/questdb/py-questdb-client/issues/51. Closes https://github.com/questdb/py-questdb-client/issues/62.
For the related Rust/C client changes, see https://github.com/questdb/c-questdb-client/pull/50 and https://github.com/questdb/c-questdb-client/pull/54
Overview
Sender.from_conf
andSender.from_env
APIs which will simplify construction of the sender.at=
argument in.row()
and.dataframe()
methods mandatory.Tasks
c-questdb-client
code.at=..
KW parameter required inrow
anddataframe
API, new "ServerNow" for oldat=None
behaviour.Sender::from_conf('...', **kwargs)
.with sender.transaction()
to temporarily disable auto-flushing.sender.flush(buffer, transactional=True)
.with sender:
block: Final flush should still happen.sender.transaction()
.init_buf_size
andmax_buf_size
params._FLUSH_FMT
for HTTP.from_conf
example and register it with the manifest filetxn.commit()
multiple times.sender.flush()
from within atxn
block.Closes https://github.com/questdb/py-questdb-client/issues/51. Closes https://github.com/questdb/py-questdb-client/issues/62.