LSST Applications 27.0.0,g0265f82a02+469cd937ee,g02d81e74bb+21ad69e7e1,g1470d8bcf6+cbe83ee85a,g2079a07aa2+e67c6346a6,g212a7c68fe+04a9158687,g2305ad1205+94392ce272,g295015adf3+81dd352a9d,g2bbee38e9b+469cd937ee,g337abbeb29+469cd937ee,g3939d97d7f+72a9f7b576,g487adcacf7+71499e7cba,g50ff169b8f+5929b3527e,g52b1c1532d+a6fc98d2e7,g591dd9f2cf+df404f777f,g5a732f18d5+be83d3ecdb,g64a986408d+21ad69e7e1,g858d7b2824+21ad69e7e1,g8a8a8dda67+a6fc98d2e7,g99cad8db69+f62e5b0af5,g9ddcbc5298+d4bad12328,ga1e77700b3+9c366c4306,ga8c6da7877+71e4819109,gb0e22166c9+25ba2f69a1,gb6a65358fc+469cd937ee,gbb8dafda3b+69d3c0e320,gc07e1c2157+a98bf949bb,gc120e1dc64+615ec43309,gc28159a63d+469cd937ee,gcf0d15dbbd+72a9f7b576,gdaeeff99f8+a38ce5ea23,ge6526c86ff+3a7c1ac5f1,ge79ae78c31+469cd937ee,gee10cc3b42+a6fc98d2e7,gf1cff7945b+21ad69e7e1,gfbcc870c63+9a11dc8c8f
LSST Data Management Base Package
|
Public Member Functions | |
ApdbReplica | from_config (cls, ApdbConfig config) |
ApdbReplica | from_uri (cls, ResourcePathExpression uri) |
VersionTuple | apdbReplicaImplementationVersion (cls) |
list[ReplicaChunk]|None | getReplicaChunks (self) |
None | deleteReplicaChunks (self, Iterable[int] chunks) |
ApdbTableData | getDiaObjectsChunks (self, Iterable[int] chunks) |
ApdbTableData | getDiaSourcesChunks (self, Iterable[int] chunks) |
ApdbTableData | getDiaForcedSourcesChunks (self, Iterable[int] chunks) |
Abstract interface for APDB replication methods.
Definition at line 109 of file apdbReplica.py.
VersionTuple lsst.dax.apdb.apdbReplica.ApdbReplica.apdbReplicaImplementationVersion | ( | cls | ) |
Return version number for current ApdbReplica implementation. Returns ------- version : `VersionTuple` Version of the code defined in implementation class.
Reimplemented in lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica, and lsst.dax.apdb.sql.apdbSqlReplica.ApdbSqlReplica.
Definition at line 163 of file apdbReplica.py.
None lsst.dax.apdb.apdbReplica.ApdbReplica.deleteReplicaChunks | ( | self, | |
Iterable[int] | chunks ) |
Remove replication chunks from the database. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to remove. Notes ----- This method causes Apdb to forget about specified chunks. If there are any auxiliary data associated with the identifiers, it is also removed from database (but data in regular tables is not removed). This method should be called after successful transfer of data from APDB to PPDB to free space used by replicas.
Reimplemented in lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica, and lsst.dax.apdb.sql.apdbSqlReplica.ApdbSqlReplica.
Definition at line 187 of file apdbReplica.py.
ApdbReplica lsst.dax.apdb.apdbReplica.ApdbReplica.from_config | ( | cls, | |
ApdbConfig | config ) |
Create ApdbReplica instance from configuration object. Parameters ---------- config : `ApdbConfig` Configuration object, type of this object determines type of the ApdbReplica implementation. Returns ------- replica : `ApdbReplica` Instance of `ApdbReplica` class.
Definition at line 113 of file apdbReplica.py.
ApdbReplica lsst.dax.apdb.apdbReplica.ApdbReplica.from_uri | ( | cls, | |
ResourcePathExpression | uri ) |
Make ApdbReplica instance from a serialized configuration. Parameters ---------- uri : `~lsst.resources.ResourcePathExpression` URI or local file path pointing to a file with serialized configuration, or a string with a "label:" prefix. In the latter case, the configuration will be looked up from an APDB index file using the label name that follows the prefix. The APDB index file's location is determined by the ``DAX_APDB_INDEX_URI`` environment variable. Returns ------- replica : `ApdbReplica` Instance of `ApdbReplica` class, the type of the returned instance is determined by configuration.
Definition at line 130 of file apdbReplica.py.
ApdbTableData lsst.dax.apdb.apdbReplica.ApdbReplica.getDiaForcedSourcesChunks | ( | self, | |
Iterable[int] | chunks ) |
Return catalog of DiaForcedSource records from given replica chunks. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to return. Returns ------- data : `ApdbTableData` Catalog containing DiaForcedSource records. In addition to all regular columns it will contain ``apdb_replica_chunk`` column. Notes ----- This part of API may not be very stable and can change before the implementation finalizes.
Reimplemented in lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica, and lsst.dax.apdb.sql.apdbSqlReplica.ApdbSqlReplica.
Definition at line 250 of file apdbReplica.py.
ApdbTableData lsst.dax.apdb.apdbReplica.ApdbReplica.getDiaObjectsChunks | ( | self, | |
Iterable[int] | chunks ) |
Return catalog of DiaObject records from given replica chunks. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to return. Returns ------- data : `ApdbTableData` Catalog containing DiaObject records. In addition to all regular columns it will contain ``apdb_replica_chunk`` column. Notes ----- This part of API may not be very stable and can change before the implementation finalizes.
Reimplemented in lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica, and lsst.dax.apdb.sql.apdbSqlReplica.ApdbSqlReplica.
Definition at line 206 of file apdbReplica.py.
ApdbTableData lsst.dax.apdb.apdbReplica.ApdbReplica.getDiaSourcesChunks | ( | self, | |
Iterable[int] | chunks ) |
Return catalog of DiaSource records from given replica chunks. Parameters ---------- chunks : `~collections.abc.Iterable` [`int`] Chunk identifiers to return. Returns ------- data : `ApdbTableData` Catalog containing DiaSource records. In addition to all regular columns it will contain ``apdb_replica_chunk`` column. Notes ----- This part of API may not be very stable and can change before the implementation finalizes.
Reimplemented in lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica, and lsst.dax.apdb.sql.apdbSqlReplica.ApdbSqlReplica.
Definition at line 228 of file apdbReplica.py.
list[ReplicaChunk] | None lsst.dax.apdb.apdbReplica.ApdbReplica.getReplicaChunks | ( | self | ) |
Return collection of replication chunks known to the database. Returns ------- chunks : `list` [`ReplicaChunk`] or `None` List of chunks, they may be time-ordered if database supports ordering. `None` is returned if database is not configured for replication.
Reimplemented in lsst.dax.apdb.cassandra.apdbCassandraReplica.ApdbCassandraReplica, and lsst.dax.apdb.sql.apdbSqlReplica.ApdbSqlReplica.
Definition at line 174 of file apdbReplica.py.