lsst.dax.apdb.cassandra.connectionContext.ConnectionContext Class Reference

Public Member Functions
	__init__ (self, Session session, ApdbCassandraConfig config, Mapping[ApdbTables, Table] table_schemas)
ApdbCassandraTimePartitionRange|None	time_partitions_range (self)

Public Attributes
	session = session
	metadata
	config = freezer.update(config, config_json)
DbVersions	db_versions = self._readVersions(self.metadata)
bool	has_chunk_sub_partitions = False
bool	has_update_record_chunks_table = False
DbVersions	has_time_partition_meta = VersionTuple(0, 1, 3)
DbVersions	has_visit_detector_table = VersionTuple(0, 1, 2)
DbVersions	has_dia_object_last_to_partition = VersionTuple(0, 1, 1)
	preparer = PreparedStatementCache(self.session)
	partitioner = Partitioner(self.config)
	schema

Static Public Attributes
str	metadataSchemaVersionKey = "version:schema"
str	metadataCodeVersionKey = "version:ApdbCassandra"
str	metadataReplicaVersionKey = "version:ApdbCassandraReplica"
str	metadataConfigKey = "config:apdb-cassandra.json"
tuple	frozen_parameters

Protected Member Functions
DbVersions	_readVersions (self, ApdbMetadataCassandra metadata)

Detailed Description

Container for all kinds ob objects that are instantiated once the
connection to Cassandra is established.

Parameters
----------
session : `cassandra.cluster.Sesion`
    Cassandra session.
config : `ApdbCassandraConfig`
    Configuration object.
table_schemas : `~collection.abc.Mapping` [`ApdbTables`, `Table`]
    Schema definitions for regular APDB tables.

Member Function Documentation

_readVersions()

DbVersions lsst.dax.apdb.cassandra.connectionContext.ConnectionContext._readVersions ( self, ApdbMetadataCassandra metadata )

protected

Read versions of all objects from metadata.

time_partitions_range()

ApdbCassandraTimePartitionRange | None lsst.dax.apdb.cassandra.connectionContext.ConnectionContext.time_partitions_range

(

self

)

Time partition range or None if instance does not use
time-partitioned tables (`ApdbCassandraTimePartitionRange` or `None`).

Member Data Documentation

frozen_parameters

tuple lsst.dax.apdb.cassandra.connectionContext.ConnectionContext.frozen_parameters

static

Initial value:

=  (
        "enable_replica",
        "ra_dec_columns",
        "replica_skips_diaobjects",
        "replica_sub_chunk_count",
        "partitioning.part_pixelization",
        "partitioning.part_pix_level",
        "partitioning.time_partition_tables",
        "partitioning.time_partition_days",
    )

metadata

lsst.dax.apdb.cassandra.connectionContext.ConnectionContext.metadata

Initial value:

=  ApdbMetadataCassandra(
            self.session, meta_table_name, config.keyspace, "read_tuples", "write"
        )

schema

lsst.dax.apdb.cassandra.connectionContext.ConnectionContext.schema

Initial value:

=  ApdbCassandraSchema(
            session=self.session,
            keyspace=self.config.keyspace,
            table_schemas=table_schemas,
            prefix=self.config.prefix,
            time_partition_tables=self.config.partitioning.time_partition_tables,
            enable_replica=self.config.enable_replica,
            replica_skips_diaobjects=self.config.replica_skips_diaobjects,
            has_chunk_sub_partitions=self.has_chunk_sub_partitions,
            has_visit_detector_table=self.has_visit_detector_table,
        )

---

The documentation for this class was generated from the following file:

• python/lsst/dax/apdb/cassandra/connectionContext.py