Inheritance diagram for lsst.dax.apdb.cassandra.apdbCassandra.ApdbCassandraConfig:
Static Public Attributes | |
| contact_points | |
| private_ips = ListField[str](doc="List of internal IP addresses for contact_points.", default=[]) | |
| port = Field[int](doc="Port number to connect to.", default=9042) | |
| keyspace = Field[str](doc="Default keyspace for operations.", default="apdb") | |
| username | |
| read_consistency | |
| write_consistency | |
| read_timeout = Field[float](doc="Timeout in seconds for read operations.", default=120.0) | |
| write_timeout = Field[float](doc="Timeout in seconds for write operations.", default=10.0) | |
| remove_timeout = Field[float](doc="Timeout in seconds for remove operations.", default=600.0) | |
| read_concurrency = Field[int](doc="Concurrency level for read operations.", default=500) | |
| protocol_version | |
| dia_object_columns | |
| prefix = Field[str](doc="Prefix to add to table names", default="") | |
| part_pixelization | |
| part_pix_level = Field[int](doc="Pixelization level used for partitioning index.", default=10) | |
| part_pix_max_ranges = Field[int](doc="Max number of ranges in pixelization envelope", default=64) | |
| ra_dec_columns = ListField[str](default=["ra", "dec"], doc="Names of ra/dec columns in DiaObject table") | |
| timer = Field[bool](doc="If True then print/log timing information", default=False) | |
| time_partition_tables | |
| time_partition_days | |
| time_partition_start | |
| time_partition_end | |
| query_per_time_part | |
| query_per_spatial_part | |
| use_insert_id_skips_diaobjects | |
Detailed Description
Configuration class for Cassandra-based APDB implementation.
Definition at line 100 of file apdbCassandra.py.
Member Data Documentation
◆ contact_points
|
static |
Initial value:
= ListField[str](
doc="The list of contact points to try connecting for cluster discovery.", default=["127.0.0.1"]
)
Definition at line 103 of file apdbCassandra.py.
◆ dia_object_columns
|
static |
Initial value:
= ListField[str](
doc="List of columns to read from DiaObject[Last], by default read all columns", default=[]
)
Definition at line 127 of file apdbCassandra.py.
◆ keyspace
|
static |
Definition at line 108 of file apdbCassandra.py.
◆ part_pix_level
|
static |
Definition at line 136 of file apdbCassandra.py.
◆ part_pix_max_ranges
|
static |
Definition at line 137 of file apdbCassandra.py.
◆ part_pixelization
|
static |
Initial value:
= ChoiceField[str](
allowed=dict(htm="HTM pixelization", q3c="Q3C pixelization", mq3c="MQ3C pixelization"),
doc="Pixelization used for partitioning index.",
default="mq3c",
)
Definition at line 131 of file apdbCassandra.py.
◆ port
|
static |
Definition at line 107 of file apdbCassandra.py.
◆ prefix
|
static |
Definition at line 130 of file apdbCassandra.py.
◆ private_ips
|
static |
Definition at line 106 of file apdbCassandra.py.
◆ protocol_version
|
static |
Initial value:
= Field[int](
doc="Cassandra protocol version to use, default is V4",
default=cassandra.ProtocolVersion.V4 if CASSANDRA_IMPORTED else 0,
)
Definition at line 123 of file apdbCassandra.py.
◆ query_per_spatial_part
|
static |
Initial value:
= Field[bool](
default=False,
doc="If True then build one query per spatial partition, otherwise build single query.",
)
Definition at line 171 of file apdbCassandra.py.
◆ query_per_time_part
|
static |
Initial value:
= Field[bool](
default=False,
doc=(
"If True then build separate query for each time partition, otherwise build one single query. "
"This is only used when time_partition_tables is False in schema config."
),
)
Definition at line 164 of file apdbCassandra.py.
◆ ra_dec_columns
|
static |
Definition at line 138 of file apdbCassandra.py.
◆ read_concurrency
|
static |
Definition at line 122 of file apdbCassandra.py.
◆ read_consistency
|
static |
Initial value:
= Field[str](
doc="Name for consistency level of read operations, default: QUORUM, can be ONE.", default="QUORUM"
)
Definition at line 113 of file apdbCassandra.py.
◆ read_timeout
|
static |
Definition at line 119 of file apdbCassandra.py.
◆ remove_timeout
|
static |
Definition at line 121 of file apdbCassandra.py.
◆ time_partition_days
|
static |
Initial value:
= Field[int](
doc=(
"Time partitioning granularity in days, this value must not be changed after database is "
"initialized"
),
default=30,
)
Definition at line 143 of file apdbCassandra.py.
◆ time_partition_end
|
static |
Initial value:
= Field[str](
doc=(
"Ending time for per-partition tables, in yyyy-mm-ddThh:mm:ss format, in TAI. "
"This is used only when time_partition_tables is True."
),
default="2030-01-01T00:00:00",
)
Definition at line 157 of file apdbCassandra.py.
◆ time_partition_start
|
static |
Initial value:
= Field[str](
doc=(
"Starting time for per-partition tables, in yyyy-mm-ddThh:mm:ss format, in TAI. "
"This is used only when time_partition_tables is True."
),
default="2018-12-01T00:00:00",
)
Definition at line 150 of file apdbCassandra.py.
◆ time_partition_tables
|
static |
Initial value:
= Field[bool](
doc="Use per-partition tables for sources instead of partitioning by time", default=False
)
Definition at line 140 of file apdbCassandra.py.
◆ timer
|
static |
Definition at line 139 of file apdbCassandra.py.
◆ use_insert_id_skips_diaobjects
|
static |
Initial value:
= Field[bool](
default=False,
doc=(
"If True then do not store DiaObjects when use_insert_id is True "
"(DiaObjectsChunks has the same data)."
),
)
Definition at line 175 of file apdbCassandra.py.
◆ username
|
static |
Initial value:
= Field[str](
doc=f"Cassandra user name, if empty then {DB_AUTH_PATH} has to provide it with password.",
default="",
)
Definition at line 109 of file apdbCassandra.py.
◆ write_consistency
|
static |
Initial value:
= Field[str](
doc="Name for consistency level of write operations, default: QUORUM, can be ONE.", default="QUORUM"
)
Definition at line 116 of file apdbCassandra.py.
◆ write_timeout
|
static |
Definition at line 120 of file apdbCassandra.py.
The documentation for this class was generated from the following file:
- /j/snowflake/release/lsstsw/stack/lsst-scipipe-8.0.0/Linux64/dax_apdb/g295015adf3+81dd352a9d/python/lsst/dax/apdb/cassandra/apdbCassandra.py
