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, object]]

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

• AssertionErrorCheck

class AssertionErrorCheck (...)

Assertion failed.

Ancestors

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

Subclasses

• AssertionErrorCheckEqual
• AssertionErrorCheckGTE
• AssertionErrorCheckNotEqual

class AssertionErrorCheckEqual (...)

Assertion failed.

Ancestors

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

class AssertionErrorCheckGTE (...)

Assertion failed.

Ancestors

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

class AssertionErrorCheckNotEqual (...)

Assertion failed.

Ancestors

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

class AsyncPipelineFullError (...)

Unspecified run-time error.

Ancestors

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

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

• ExpirableEntry
• Entry
• pybind11_builtins.pybind11_object

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

• ExpirableEntry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • expires_at
  • expires_from_now
  • get_entry_type
  • get_expiry_time
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

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, enable_encryption: bool = False, client_max_parallelism: int = 0) -> 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 properties(...)

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

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 reader(...)

reader(self: quasardb.quasardb.Cluster, table_names: list[str], *, column_names: list[str] = [], batch_size: int = 0, ranges: list[tuple] = []) -> qdb::reader

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: object) -> 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

• ExpirableEntry
• Entry
• pybind11_builtins.pybind11_object

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

• ExpirableEntry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • expires_at
  • expires_from_now
  • get_entry_type
  • get_expiry_time
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

class Entry (...)

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

Ancestors

• pybind11_builtins.pybind11_object

Subclasses

• ExpirableEntry
• Table
• Tag

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

• AliasAlreadyExistsError
• AliasNotFoundError
• AsyncPipelineFullError
• IncompatibleTypeError
• InputBufferTooSmallError
• InternalLocalError
• InvalidArgumentError
• InvalidDatetimeError
• InvalidHandleError
• InvalidQueryError
• NotImplementedError
• OutOfBoundsError
• TryAgainError
• UninitializedError

class ExpirableEntry (...)

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

Ancestors

• Entry
• pybind11_builtins.pybind11_object

Subclasses

• Blob
• Double
• Integer
• String
• Timestamp

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

• Entry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • get_entry_type
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

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

• ExpirableEntry
• Entry
• pybind11_builtins.pybind11_object

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

• ExpirableEntry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • expires_at
  • expires_from_now
  • get_entry_type
  • get_expiry_time
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

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 MockFailureOptions (...)

init(self: quasardb.quasardb.MockFailureOptions, failures: int = 0) -> None

Ancestors

• pybind11_builtins.pybind11_object

Instance variables

var failures_left

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

Methods

def has_next(...)

has_next(self: quasardb.quasardb.MockFailureOptions) -> bool

def next(...)

next(self: quasardb.quasardb.MockFailureOptions) -> quasardb.quasardb.MockFailureOptions

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 = '', enable_encryption: bool = False) -> 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

 

Balanced

 

var Encryption

Encryption type

Members

Disabled

 

AES256GCM

 

Methods

def disable_user_properties(...)

disable_user_properties(self: quasardb.quasardb.Options) -> None

def enable_user_properties(...)

enable_user_properties(self: quasardb.quasardb.Options) -> None

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 get_timezone(...)

get_timezone(self: quasardb.quasardb.Options) -> str

def set_client_max_in_buf_size(...)

set_client_max_in_buf_size(self: quasardb.quasardb.Options, arg0: 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_timezone(...)

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

def set_user_credentials(...)

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

class OutOfBoundsError (...)

Unspecified run-time error.

Ancestors

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

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 Properties (...)

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

Ancestors

• pybind11_builtins.pybind11_object

Methods

def clear(...)

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

def get(...)

get(self: quasardb.quasardb.Properties, arg0: str) -> Optional[str]

def put(...)

put(self: quasardb.quasardb.Properties, arg0: str, arg1: str) -> None

def remove(...)

remove(self: quasardb.quasardb.Properties, arg0: str) -> None

class QueryContinuous (...)

init(self: quasardb.quasardb.QueryContinuous, arg0: qdb::handle, arg1: object) -> None

Ancestors

• pybind11_builtins.pybind11_object

Methods

def probe_results(...)

probe_results(self: quasardb.quasardb.QueryContinuous) -> list[dict[str, object]]

def results(...)

results(self: quasardb.quasardb.QueryContinuous) -> list[dict[str, object]]

def run(...)

run(self: quasardb.quasardb.QueryContinuous, arg0: qdb_query_continuous_mode_type_t, arg1: datetime.timedelta, arg2: str) -> None

def stop(...)

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

class Reader (...)

init(self: quasardb.quasardb.Reader, conn: qdb::handle, table_names: list[str], *, column_names: list[str] = [], batch_size: int = 65536, ranges: list[tuple] = []) -> None

Ancestors

• pybind11_builtins.pybind11_object

Methods

def get_batch_size(...)

get_batch_size(self: quasardb.quasardb.Reader) -> int

class RetryOptions (...)

init(self: quasardb.quasardb.RetryOptions, retries: int = 3, *, delay: datetime.timedelta = datetime.timedelta(seconds=3), exponent: int = 2, jitter: float = 0.1) -> None

Ancestors

• pybind11_builtins.pybind11_object

Instance variables

var delay

(self: quasardb.quasardb.RetryOptions) -> datetime.timedelta

var exponent

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

var jitter

(self: quasardb.quasardb.RetryOptions) -> float

var retries_left

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

Methods

def has_next(...)

has_next(self: quasardb.quasardb.RetryOptions) -> bool

def next(...)

next(self: quasardb.quasardb.RetryOptions) -> quasardb.quasardb.RetryOptions

class String (...)

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

Ancestors

• ExpirableEntry
• Entry
• pybind11_builtins.pybind11_object

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

• ExpirableEntry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • expires_at
  • expires_from_now
  • get_entry_type
  • get_expiry_time
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

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_shard_size(...)

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

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, *, column_names: list[str] = [], batch_size: int = 0, ranges: list[tuple] = []) -> qdb::reader

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

• Entry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • get_entry_type
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

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

• Entry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • get_entry_type
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

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 Timestamp (...)

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

Ancestors

• ExpirableEntry
• Entry
• pybind11_builtins.pybind11_object

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

• ExpirableEntry:
  • Type
  • attach_tag
  • attach_tags
  • detach_tag
  • detach_tags
  • exists
  • expires_at
  • expires_from_now
  • get_entry_type
  • get_expiry_time
  • get_location
  • get_metadata
  • get_name
  • get_tags
  • has_tag
  • remove

class TryAgainError (...)

Unspecified run-time error.

Ancestors

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

class UninitializedError (...)

Unspecified run-time error.

Ancestors

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

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: object, column_data: list) -> None

Append new data

def empty(...)

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

Returns true if underlying data is empty

class WriterPushMode (...)

Push Mode

Members

Transactional

 

Fast

 

Truncate

 

Async

 

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

Ancestors

• pybind11_builtins.pybind11_object

Class variables

var Async

var Fast

var Transactional

var Truncate

Instance variables

var name

name(self: object) -> str

var value

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