Module quasardb.quasardb

QuasarDB Official Python API

Sub-modules

quasardb.pool
quasardb.stats
quasardb.numpy
quasardb.pandas

Functions

def build(...)

build() -> str

Return build number

def dict_query(...)

dict_query(arg0: qdb::handle, arg1: str, arg2: object) -> List[Dict[str, handle]]

def version(...)

version() -> str

Return version number

Classes

class AliasAlreadyExistsError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class AliasNotFoundError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class AssertionError (...)

Assertion failed.

Ancestors

  • builtins.AssertionError
  • builtins.Exception
  • builtins.BaseException

Subclasses

class AssertionErrorCheck (...)

Assertion failed.

Ancestors

  • AssertionError
  • builtins.AssertionError
  • builtins.Exception
  • builtins.BaseException

Subclasses

class AssertionErrorCheckEqual (...)

Assertion failed.

Ancestors

class AssertionErrorCheckGTE (...)

Assertion failed.

Ancestors

class AssertionErrorCheckNotEqual (...)

Assertion failed.

Ancestors

class BatchColumnInfo (...)

init(self: quasardb.quasardb.BatchColumnInfo, ts_name: str, col_name: str, size_hint: int = 0) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Instance variables

var column

(self: quasardb.quasardb.BatchColumnInfo) -> str

var elements_count_hint

(self: quasardb.quasardb.BatchColumnInfo) -> int

var timeseries

(self: quasardb.quasardb.BatchColumnInfo) -> str

class Blob (...)

init(self: quasardb.quasardb.Blob, arg0: qdb::handle, arg1: str) -> None

Ancestors

Methods

def compare_and_swap(...)

compare_and_swap(self: quasardb.quasardb.Blob, new_content: str, comparand: str) -> bytes

def get(...)

get(self: quasardb.quasardb.Blob) -> bytes

def get_and_remove(...)

get_and_remove(self: quasardb.quasardb.Blob) -> bytes

def get_and_update(...)

get_and_update(self: quasardb.quasardb.Blob, data: str) -> bytes

def put(...)

put(self: quasardb.quasardb.Blob, data: str) -> None

def remove_if(...)

remove_if(self: quasardb.quasardb.Blob, comparand: str) -> None

def update(...)

update(self: quasardb.quasardb.Blob, data: str, expiry: datetime.datetime = datetime.datetime(1970, 1, 1, 0, 0)) -> None

Inherited members

class Cluster (...)

Represents a connection to the QuasarDB cluster.

init(self: quasardb.quasardb.Cluster, uri: str, user_name: str = '', user_private_key: str = '', cluster_public_key: str = '', user_security_file: str = '', cluster_public_key_file: str = '', timeout: datetime.timedelta = datetime.timedelta(seconds=60), do_version_check: bool = False) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def blob(...)

blob(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::blob_entry

def close(...)

close(self: quasardb.quasardb.Cluster) -> None

def compact_abort(...)

compact_abort(self: quasardb.quasardb.Cluster) -> None

def compact_full(...)

compact_full(self: quasardb.quasardb.Cluster) -> None

def compact_progress(...)

compact_progress(self: quasardb.quasardb.Cluster) -> int

def double(...)

double(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::double_entry

def endpoints(...)

endpoints(self: quasardb.quasardb.Cluster) -> List[str]

def find(...)

find(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::find_query

def get_memory_info(...)

get_memory_info(self: quasardb.quasardb.Cluster) -> str

def inserter(...)

inserter(self: quasardb.quasardb.Cluster, arg0: List[qdb::batch_column_info]) -> qdb::batch_inserter

def integer(...)

integer(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::integer_entry

def is_open(...)

is_open(self: quasardb.quasardb.Cluster) -> bool

def node(...)

node(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::node

def node_config(...)

node_config(self: quasardb.quasardb.Cluster, arg0: str) -> object

def node_status(...)

node_status(self: quasardb.quasardb.Cluster, arg0: str) -> object

def node_topology(...)

node_topology(self: quasardb.quasardb.Cluster, arg0: str) -> object

def options(...)

options(self: quasardb.quasardb.Cluster) -> qdb::options

def perf(...)

perf(self: quasardb.quasardb.Cluster) -> qdb::perf

def pinned_writer(...)

pinned_writer(self: quasardb.quasardb.Cluster) -> qdb::writer

def prefix_count(...)

prefix_count(self: quasardb.quasardb.Cluster, arg0: str) -> int

def prefix_get(...)

prefix_get(self: quasardb.quasardb.Cluster, arg0: str, arg1: int) -> List[str]

def purge_all(...)

purge_all(self: quasardb.quasardb.Cluster, arg0: datetime.timedelta) -> None

def purge_cache(...)

purge_cache(self: quasardb.quasardb.Cluster, arg0: datetime.timedelta) -> None

def query(...)

query(self: quasardb.quasardb.Cluster, query: str, blobs: object = False) -> object

def query_continuous_full(...)

query_continuous_full(self: quasardb.quasardb.Cluster, query: str, pace: datetime.timedelta, blobs: object = False) -> qdb::query_continuous

def query_continuous_new_values(...)

query_continuous_new_values(self: quasardb.quasardb.Cluster, query: str, pace: datetime.timedelta, blobs: object = False) -> qdb::query_continuous

def query_numpy(...)

query_numpy(self: quasardb.quasardb.Cluster, query: str) -> object

def string(...)

string(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::string_entry

def suffix_count(...)

suffix_count(self: quasardb.quasardb.Cluster, arg0: str) -> int

def suffix_get(...)

suffix_get(self: quasardb.quasardb.Cluster, arg0: str, arg1: int) -> List[str]

def table(...)

table(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::table

def tag(...)

tag(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::tag

def tidy_memory(...)

tidy_memory(self: quasardb.quasardb.Cluster) -> None

def timestamp(...)

timestamp(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::timestamp_entry

def trim_all(...)

trim_all(self: quasardb.quasardb.Cluster, arg0: datetime.timedelta, arg1: datetime.timedelta) -> None

def ts(...)

ts(self: quasardb.quasardb.Cluster, arg0: str) -> qdb::table

def ts_batch(...)

ts_batch(self: quasardb.quasardb.Cluster, arg0: List[qdb::batch_column_info]) -> qdb::batch_inserter

def uri(...)

uri(self: quasardb.quasardb.Cluster) -> str

def wait_for_compaction(...)

wait_for_compaction(self: quasardb.quasardb.Cluster) -> None

def writer(...)

writer(self: quasardb.quasardb.Cluster) -> qdb::writer

class ColumnInfo (...)

init(args, *kwargs) Overloaded function.

  1. init(self: quasardb.quasardb.ColumnInfo, arg0: quasardb.quasardb.ColumnType, arg1: str) -> None

  2. init(self: quasardb.quasardb.ColumnInfo, arg0: quasardb.quasardb.ColumnType, arg1: str, arg2: str) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Instance variables

var name

(self: quasardb.quasardb.ColumnInfo) -> str

var symtable

(self: quasardb.quasardb.ColumnInfo) -> str

var type

(self: quasardb.quasardb.ColumnInfo) -> quasardb.quasardb.ColumnType

class ColumnType (...)

Column type

Members

Uninitialized
 
Double
 
Blob
 
String
 
Symbol
 
Int64
 
Timestamp
 

init(self: quasardb.quasardb.ColumnType, value: int) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Class variables

var Blob
var Double
var Int64
var String
var Symbol
var Timestamp
var Uninitialized

Instance variables

var name

name(self: handle) -> str

var value

(arg0: quasardb.quasardb.ColumnType) -> int

class DirectBlob (...)

init(self: quasardb.quasardb.DirectBlob, arg0: qdb::handle, arg1: qdb::direct_handle, arg2: str) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def get(...)

get(self: quasardb.quasardb.DirectBlob) -> bytes

def put(...)

put(self: quasardb.quasardb.DirectBlob, data: str) -> None

def remove(...)

remove(self: quasardb.quasardb.DirectBlob) -> None

def update(...)

update(self: quasardb.quasardb.DirectBlob, data: str) -> None

class DirectInteger (...)

init(self: quasardb.quasardb.DirectInteger, arg0: qdb::handle, arg1: qdb::direct_handle, arg2: str) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def get(...)

get(self: quasardb.quasardb.DirectInteger) -> int

def put(...)

put(self: quasardb.quasardb.DirectInteger, integer: int) -> None

def remove(...)

remove(self: quasardb.quasardb.DirectInteger) -> None

def update(...)

update(self: quasardb.quasardb.DirectInteger, integer: int) -> None

class Double (...)

init(self: quasardb.quasardb.Double, arg0: qdb::handle, arg1: str) -> None

Ancestors

Methods

def add(...)

add(self: quasardb.quasardb.Double, addend: float) -> float

def get(...)

get(self: quasardb.quasardb.Double) -> float

def put(...)

put(self: quasardb.quasardb.Double, double: float) -> None

def update(...)

update(self: quasardb.quasardb.Double, double: float) -> None

Inherited members

class Entry (...)

init(self: quasardb.quasardb.Entry, arg0: qdb::handle, arg1: str) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Subclasses

Class variables

var Metadata
var Type

Entry type

Members

Uninitialized
 
Integer
 
HashSet
 
Tag
 
Deque
 
Stream
 
Timeseries
 

Methods

def attach_tag(...)

attach_tag(self: quasardb.quasardb.Entry, arg0: str) -> bool

def attach_tags(...)

attach_tags(self: quasardb.quasardb.Entry, arg0: List[str]) -> None

def detach_tag(...)

detach_tag(self: quasardb.quasardb.Entry, arg0: str) -> bool

def detach_tags(...)

detach_tags(self: quasardb.quasardb.Entry, arg0: List[str]) -> None

def exists(...)

exists(self: quasardb.quasardb.Entry) -> bool

Returns true if the entry exists

def get_entry_type(...)

get_entry_type(self: quasardb.quasardb.Entry) -> quasardb.quasardb.Entry.Type

def get_location(...)

get_location(self: quasardb.quasardb.Entry) -> Tuple[str, int]

def get_metadata(...)

get_metadata(self: quasardb.quasardb.Entry) -> qdb::entry::metadata

def get_name(...)

get_name(self: quasardb.quasardb.Entry) -> str

def get_tags(...)

get_tags(self: quasardb.quasardb.Entry) -> List[str]

def has_tag(...)

has_tag(self: quasardb.quasardb.Entry, arg0: str) -> bool

def remove(...)

remove(self: quasardb.quasardb.Entry) -> None

class Error (...)

Unspecified run-time error.

Ancestors

  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException

Subclasses

class ExpirableEntry (...)

init(self: quasardb.quasardb.ExpirableEntry, arg0: qdb::handle, arg1: str) -> None

Ancestors

  • Entry
  • pybind11_builtins.pybind11_object

Subclasses

Methods

def expires_at(...)

expires_at(self: quasardb.quasardb.ExpirableEntry, arg0: qdb::pydatetime) -> None

def expires_from_now(...)

expires_from_now(self: quasardb.quasardb.ExpirableEntry, arg0: datetime.timedelta) -> None

def get_expiry_time(...)

get_expiry_time(self: quasardb.quasardb.ExpirableEntry) -> qdb::pydatetime

Inherited members

class FindQuery (...)

init(self: quasardb.quasardb.FindQuery, arg0: qdb::handle, arg1: str) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def run(...)

run(self: quasardb.quasardb.FindQuery) -> List[str]

class IncompatibleTypeError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class IndexedColumnInfo (...)

init(args, *kwargs) Overloaded function.

  1. init(self: quasardb.quasardb.IndexedColumnInfo, arg0: quasardb.quasardb.ColumnType, arg1: int) -> None

  2. init(self: quasardb.quasardb.IndexedColumnInfo, arg0: quasardb.quasardb.ColumnType, arg1: int, arg2: str) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Instance variables

var index

(self: quasardb.quasardb.IndexedColumnInfo) -> int

var symtable

(self: quasardb.quasardb.IndexedColumnInfo) -> str

var type

(self: quasardb.quasardb.IndexedColumnInfo) -> quasardb.quasardb.ColumnType

class InputBufferTooSmallError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class Integer (...)

init(self: quasardb.quasardb.Integer, arg0: qdb::handle, arg1: str) -> None

Ancestors

Methods

def add(...)

add(self: quasardb.quasardb.Integer, addend: int) -> int

def get(...)

get(self: quasardb.quasardb.Integer) -> int

def put(...)

put(self: quasardb.quasardb.Integer, integer: int) -> None

def update(...)

update(self: quasardb.quasardb.Integer, integer: int) -> None

Inherited members

class InternalLocalError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class InvalidArgumentError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class InvalidDatetimeError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class InvalidHandleError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class InvalidQueryError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class MaskedArray (...)

Ancestors

  • pybind11_builtins.pybind11_object
class Node (...)

init(self: quasardb.quasardb.Node, uri: str, user_name: str = '', user_private_key: str = '', cluster_public_key: str = '', user_security_file: str = '', cluster_public_key_file: str = '') -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def blob(...)

blob(self: quasardb.quasardb.Node, arg0: str) -> qdb::direct_blob_entry

def integer(...)

integer(self: quasardb.quasardb.Node, arg0: str) -> qdb::direct_integer_entry

def prefix_get(...)

prefix_get(self: quasardb.quasardb.Node, arg0: str, arg1: int) -> List[str]

class NotImplementedError (...)

Unspecified run-time error.

Ancestors

  • Error
  • builtins.RuntimeError
  • builtins.Exception
  • builtins.BaseException
class Options (...)

init(self: quasardb.quasardb.Options, arg0: qdb::handle) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Class variables

var Compression

Compression type

Members

Disabled
 
Fast
 
Best
 
var Encryption

Encryption type

Members

Disabled
 
AES256GCM
 

Methods

def get_client_max_in_buf_size(...)

get_client_max_in_buf_size(self: quasardb.quasardb.Options) -> int

def get_client_max_parallelism(...)

get_client_max_parallelism(self: quasardb.quasardb.Options) -> int

def get_cluster_max_in_buf_size(...)

get_cluster_max_in_buf_size(self: quasardb.quasardb.Options) -> int

def get_query_max_length(...)

get_query_max_length(self: quasardb.quasardb.Options) -> int

def get_stabilization_max_wait(...)

get_stabilization_max_wait(self: quasardb.quasardb.Options) -> datetime.timedelta

def get_timeout(...)

get_timeout(self: quasardb.quasardb.Options) -> datetime.timedelta

def set_client_max_in_buf_size(...)

set_client_max_in_buf_size(self: quasardb.quasardb.Options, arg0: int) -> None

def set_client_max_parallelism(...)

set_client_max_parallelism(self: quasardb.quasardb.Options, parallelism: int) -> None

def set_client_soft_memory_limit(...)

set_client_soft_memory_limit(self: quasardb.quasardb.Options, limit: int) -> None

def set_cluster_public_key(...)

set_cluster_public_key(self: quasardb.quasardb.Options, arg0: str) -> None

def set_compression(...)

set_compression(self: quasardb.quasardb.Options, arg0: quasardb.quasardb.Options.Compression) -> None

def set_encryption(...)

set_encryption(self: quasardb.quasardb.Options, arg0: quasardb.quasardb.Options.Encryption) -> None

def set_max_cardinality(...)

set_max_cardinality(self: quasardb.quasardb.Options, arg0: int) -> None

def set_query_max_length(...)

set_query_max_length(self: quasardb.quasardb.Options, query_max_length: int) -> None

def set_stabilization_max_wait(...)

set_stabilization_max_wait(self: quasardb.quasardb.Options, arg0: datetime.timedelta) -> None

def set_timeout(...)

set_timeout(self: quasardb.quasardb.Options, arg0: datetime.timedelta) -> None

def set_user_credentials(...)

set_user_credentials(self: quasardb.quasardb.Options, arg0: str, arg1: str) -> None

class Perf (...)

init(self: quasardb.quasardb.Perf, arg0: qdb::handle) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def clear(...)

clear(self: quasardb.quasardb.Perf) -> None

def disable(...)

disable(self: quasardb.quasardb.Perf) -> None

def enable(...)

enable(self: quasardb.quasardb.Perf) -> None

def get(...)

get(self: quasardb.quasardb.Perf, flame: bool = False, outfile: str = '') -> object

class QueryContinuous (...)

init(self: quasardb.quasardb.QueryContinuous, arg0: qdb::handle, arg1: qdb_query_continuous_mode_type_t, arg2: datetime.timedelta, arg3: str, arg4: object) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def probe_results(...)

probe_results(self: quasardb.quasardb.QueryContinuous) -> List[Dict[str, handle]]

def results(...)

results(self: quasardb.quasardb.QueryContinuous) -> List[Dict[str, handle]]

def stop(...)

stop(self: quasardb.quasardb.QueryContinuous) -> None

class String (...)

init(self: quasardb.quasardb.String, arg0: qdb::handle, arg1: str) -> None

Ancestors

Methods

def compare_and_swap(...)

compare_and_swap(self: quasardb.quasardb.String, new_content: str, comparand: str) -> str

def get(...)

get(self: quasardb.quasardb.String) -> str

def get_and_remove(...)

get_and_remove(self: quasardb.quasardb.String) -> str

def get_and_update(...)

get_and_update(self: quasardb.quasardb.String, data: str) -> str

def put(...)

put(self: quasardb.quasardb.String, data: str) -> None

def remove_if(...)

remove_if(self: quasardb.quasardb.String, comparand: str) -> None

def update(...)

update(self: quasardb.quasardb.String, data: str, expiry: datetime.datetime = datetime.datetime(1970, 1, 1, 0, 0)) -> None

Inherited members

class Table (...)

Table representation

init(self: quasardb.quasardb.Table, arg0: qdb::handle, arg1: str) -> None

Ancestors

  • Entry
  • pybind11_builtins.pybind11_object

Methods

def blob_get_ranges(...)

blob_get_ranges(self: quasardb.quasardb.Table, column: str, ranges: object = None) -> Tuple[numpy.ndarray, numpy.ma.MaskedArray]

def blob_insert(...)

blob_insert(self: quasardb.quasardb.Table, arg0: str, arg1: numpy.ndarray, arg2: numpy.ma.MaskedArray) -> None

def column_id_by_index(...)

column_id_by_index(self: quasardb.quasardb.Table, arg0: int) -> str

def column_index_by_id(...)

column_index_by_id(self: quasardb.quasardb.Table, arg0: str) -> int

def column_info_by_index(...)

column_info_by_index(self: quasardb.quasardb.Table, arg0: int) -> qdb::detail::column_info

def column_type_by_id(...)

column_type_by_id(self: quasardb.quasardb.Table, arg0: str) -> quasardb.quasardb.ColumnType

def column_type_by_index(...)

column_type_by_index(self: quasardb.quasardb.Table, arg0: int) -> quasardb.quasardb.ColumnType

def create(...)

create(self: quasardb.quasardb.Table, columns: List[qdb::detail::column_info], shard_size: datetime.timedelta = datetime.timedelta(days=1), ttl: datetime.timedelta = datetime.timedelta(0)) -> None

def double_get_ranges(...)

double_get_ranges(self: quasardb.quasardb.Table, column: str, ranges: object = None) -> Tuple[numpy.ndarray, numpy.ma.MaskedArray]

def double_insert(...)

double_insert(self: quasardb.quasardb.Table, arg0: str, arg1: numpy.ndarray, arg2: numpy.ma.MaskedArray) -> None

def erase_ranges(...)

erase_ranges(self: quasardb.quasardb.Table, arg0: str, arg1: object) -> int

def get_ttl(...)

get_ttl(self: quasardb.quasardb.Table) -> datetime.timedelta

def has_ttl(...)

has_ttl(self: quasardb.quasardb.Table) -> bool

def insert_columns(...)

insert_columns(self: quasardb.quasardb.Table, arg0: List[qdb::detail::column_info]) -> None

def int64_get_ranges(...)

int64_get_ranges(self: quasardb.quasardb.Table, column: str, ranges: object = None) -> Tuple[numpy.ndarray, numpy.ma.MaskedArray]

def int64_insert(...)

int64_insert(self: quasardb.quasardb.Table, arg0: str, arg1: numpy.ndarray, arg2: numpy.ma.MaskedArray) -> None

def list_columns(...)

list_columns(self: quasardb.quasardb.Table) -> List[qdb::detail::column_info]

def reader(...)

reader(self: quasardb.quasardb.Table, columns: List[str] = [], ranges: object = None, dict: bool = False) -> object

def retrieve_metadata(...)

retrieve_metadata(self: quasardb.quasardb.Table) -> None

def string_get_ranges(...)

string_get_ranges(self: quasardb.quasardb.Table, column: str, ranges: object = None) -> Tuple[numpy.ndarray, numpy.ma.MaskedArray]

def string_insert(...)

string_insert(self: quasardb.quasardb.Table, arg0: str, arg1: numpy.ndarray, arg2: numpy.ma.MaskedArray) -> None

def subscribe(...)

subscribe(self: quasardb.quasardb.Table, arg0: object) -> object

def timestamp_get_ranges(...)

timestamp_get_ranges(self: quasardb.quasardb.Table, column: str, ranges: object = None) -> Tuple[numpy.ndarray, numpy.ma.MaskedArray]

def timestamp_insert(...)

timestamp_insert(self: quasardb.quasardb.Table, arg0: str, arg1: numpy.ndarray, arg2: numpy.ma.MaskedArray) -> None

Inherited members

class Tag (...)

init(self: quasardb.quasardb.Tag, arg0: qdb::handle, arg1: str) -> None

Ancestors

  • Entry
  • pybind11_builtins.pybind11_object

Methods

def count(...)

count(self: quasardb.quasardb.Tag) -> int

def get_entries(...)

get_entries(self: quasardb.quasardb.Tag) -> List[str]

Inherited members

class TimeSeriesBatch (...)

init(self: quasardb.quasardb.TimeSeriesBatch, arg0: qdb::handle, arg1: List[quasardb.quasardb.BatchColumnInfo]) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def push(...)

push(self: quasardb.quasardb.TimeSeriesBatch) -> None

Regular batch push

def push_async(...)

push_async(self: quasardb.quasardb.TimeSeriesBatch) -> None

Asynchronous batch push that buffers data inside the QuasarDB daemon

def push_fast(...)

push_fast(self: quasardb.quasardb.TimeSeriesBatch) -> None

Fast, in-place batch push that is efficient when doing lots of small, incremental pushes.

def push_truncate(...)

push_truncate(self: quasardb.quasardb.TimeSeriesBatch, **kwargs) -> None

Before inserting data, truncates any existing data. This is useful when you want your insertions to be idempotent, e.g. in case of a retry.

def set_blob(...)

set_blob(self: quasardb.quasardb.TimeSeriesBatch, arg0: int, arg1: bytes) -> None

def set_double(...)

set_double(self: quasardb.quasardb.TimeSeriesBatch, arg0: int, arg1: float) -> None

def set_int64(...)

set_int64(self: quasardb.quasardb.TimeSeriesBatch, arg0: int, arg1: int) -> None

def set_string(...)

set_string(self: quasardb.quasardb.TimeSeriesBatch, arg0: int, arg1: str) -> None

def set_timestamp(...)

set_timestamp(self: quasardb.quasardb.TimeSeriesBatch, arg0: int, arg1: object) -> None

def start_row(...)

start_row(self: quasardb.quasardb.TimeSeriesBatch, arg0: object) -> None

Calling this function marks the beginning of processing a new row.

class TimeSeriesDictReader (...)

init(self: quasardb.quasardb.TimeSeriesDictReader, arg0: qdb::handle, arg1: str, arg2: List[qdb::detail::column_info], arg3: List[qdb_ts_range_t]) -> None

Ancestors

  • pybind11_builtins.pybind11_object
class TimeSeriesFastReader (...)

init(self: quasardb.quasardb.TimeSeriesFastReader, arg0: qdb::handle, arg1: str, arg2: List[qdb::detail::column_info], arg3: List[qdb_ts_range_t]) -> None

Ancestors

  • pybind11_builtins.pybind11_object
class TimeSeriesReaderDictRow (...)

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def copy(...)

copy(self: quasardb.quasardb.TimeSeriesReaderDictRow) -> Dict[str, object]

def timestamp(...)

timestamp(self: qdb::reader::ts_row) -> qdb::numpy::datetime64

class TimeSeriesReaderFastRow (...)

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def copy(...)

copy(self: quasardb.quasardb.TimeSeriesReaderFastRow) -> List[object]

def timestamp(...)

timestamp(self: qdb::reader::ts_row) -> qdb::numpy::datetime64

class TimeSeriesReaderValue (...)

Ancestors

  • pybind11_builtins.pybind11_object
class Timestamp (...)

init(self: quasardb.quasardb.Timestamp, arg0: qdb::handle, arg1: str) -> None

Ancestors

Methods

def add(...)

add(self: quasardb.quasardb.Timestamp, addend: qdb::pydatetime) -> qdb::pydatetime

def get(...)

get(self: quasardb.quasardb.Timestamp) -> qdb::pydatetime

def put(...)

put(self: quasardb.quasardb.Timestamp, timestamp: qdb::pydatetime) -> None

def update(...)

update(self: quasardb.quasardb.Timestamp, timestamp: qdb::pydatetime) -> None

Inherited members

class VectorObject (...)

init(args, *kwargs) Overloaded function.

  1. init(self: quasardb.quasardb.VectorObject) -> None

  2. init(self: quasardb.quasardb.VectorObject, arg0: List[object]) -> None

Copy constructor

  1. init(self: quasardb.quasardb.VectorObject, arg0: Iterable) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def append(...)

append(self: List[object], x: object) -> None

Add an item to the end of the list

def clear(...)

clear(self: List[object]) -> None

Clear the contents

def count(...)

count(self: List[object], x: object) -> int

Return the number of times x appears in the list

def extend(...)

extend(args, *kwargs) Overloaded function.

  1. extend(self: List[object], L: List[object]) -> None

Extend the list by appending all the items in the given list

  1. extend(self: List[object], L: Iterable) -> None

Extend the list by appending all the items in the given list

def insert(...)

insert(self: List[object], i: int, x: object) -> None

Insert an item at a given position.

def pop(...)

pop(args, *kwargs) Overloaded function.

  1. pop(self: List[object]) -> object

Remove and return the last item

  1. pop(self: List[object], i: int) -> object

Remove and return the item at index i

def remove(...)

remove(self: List[object], x: object) -> None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class WriterData (...)

init(self: quasardb.quasardb.WriterData) -> None

Ancestors

  • pybind11_builtins.pybind11_object

Methods

def append(...)

append(self: quasardb.quasardb.WriterData, table: quasardb.quasardb.Table, index: handle, column_data: list) -> None

Append new data

def empty(...)

empty(self: quasardb.quasardb.WriterData) -> bool

Returns true if underlying data is empty