LSSTApplications
19.0.0,19.0.0+1,19.0.0+10,19.0.0+13,19.0.0+3,19.0.0+5,19.0.0+9,tickets.DM-22703-ga158cbef15,w.2019.51
LSSTDataManagementBasePackage
|
Public Member Functions | |
def | __init__ (self, config, afw_schemas=None) |
def | lastVisit (self) |
def | saveVisit (self, visitId, visitTime) |
def | tableRowCount (self) |
def | getDiaObjects (self, pixel_ranges, return_pandas=False) |
def | getDiaSourcesInRegion (self, pixel_ranges, dt, return_pandas=False) |
def | getDiaSources (self, object_ids, dt, return_pandas=False) |
def | getDiaForcedSources (self, object_ids, dt, return_pandas=False) |
def | storeDiaObjects (self, objs, dt) |
def | storeDiaSources (self, sources) |
def | storeDiaForcedSources (self, sources) |
def | countUnassociatedObjects (self) |
def | isVisitProcessed (self, visitInfo) |
def | dailyJob (self) |
def | makeSchema (self, drop=False, mysql_engine='InnoDB', oracle_tablespace=None, oracle_iot=False) |
Public Attributes | |
config | |
Interface to L1 database, hides all database access details. The implementation is configured via standard ``pex_config`` mechanism using `PpdbConfig` configuration class. For an example of different configurations check config/ folder. Parameters ---------- config : `PpdbConfig` afw_schemas : `dict`, optional Dictionary with table name for a key and `afw.table.Schema` for a value. Columns in schema will be added to standard PPDB schema.
def lsst.dax.ppdb.ppdb.Ppdb.__init__ | ( | self, | |
config, | |||
afw_schemas = None |
|||
) |
Definition at line 226 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.countUnassociatedObjects | ( | self | ) |
def lsst.dax.ppdb.ppdb.Ppdb.dailyJob | ( | self | ) |
def lsst.dax.ppdb.ppdb.Ppdb.getDiaForcedSources | ( | self, | |
object_ids, | |||
dt, | |||
return_pandas = False |
|||
) |
Returns catalog of DiaForcedSource instances matching given DiaObjects. This method returns :doc:`/modules/lsst.afw.table/index` catalog with schema determined by the schema of L1 database table. Re-mapping of the column names may be done for some columns (based on column map passed to constructor) but types or units are not changed. Parameters ---------- object_ids : Collection of DiaObject IDs dt : `datetime.datetime` Time of the current visit return_pandas : `bool` Return a `pandas.DataFrame` instead of `lsst.afw.table.SourceCatalog`. Returns ------- catalog : `lsst.afw.table.SourceCatalog` or `None` Catalog contaning DiaForcedSource records. `None` is returned if ``read_sources_months`` configuration parameter is set to 0 or when ``object_ids`` is empty.
Definition at line 545 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.getDiaObjects | ( | self, | |
pixel_ranges, | |||
return_pandas = False |
|||
) |
Returns catalog of DiaObject instances from given region. Objects are searched based on pixelization index and region is determined by the set of indices. There is no assumption on a particular type of index, client is responsible for consistency when calculating pixelization indices. This method returns :doc:`/modules/lsst.afw.table/index` catalog with schema determined by the schema of PPDB table. Re-mapping of the column names is done for some columns (based on column map passed to constructor) but types or units are not changed. Returns only the last version of each DiaObject. Parameters ---------- pixel_ranges : `list` of `tuple` Sequence of ranges, range is a tuple (minPixelID, maxPixelID). This defines set of pixel indices to be included in result. return_pandas : `bool` Return a `pandas.DataFrame` instead of `lsst.afw.table.SourceCatalog`. Returns ------- catalog : `lsst.afw.table.SourceCatalog` or `pandas.DataFrame` Catalog containing DiaObject records.
Definition at line 343 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.getDiaSources | ( | self, | |
object_ids, | |||
dt, | |||
return_pandas = False |
|||
) |
Returns catalog of DiaSource instances given set of DiaObject IDs. This method returns :doc:`/modules/lsst.afw.table/index` catalog with schema determined by the schema of PPDB table. Re-mapping of the column names is done for some columns (based on column map passed to constructor) but types or units are not changed. Parameters ---------- object_ids : Collection of DiaObject IDs dt : `datetime.datetime` Time of the current visit return_pandas : `bool` Return a `pandas.DataFrame` instead of `lsst.afw.table.SourceCatalog`. Returns ------- catalog : `lsst.afw.table.SourceCatalog`, `pandas.DataFrame`, or `None` Catalog contaning DiaSource records. `None` is returned if ``read_sources_months`` configuration parameter is set to 0 or when ``object_ids`` is empty.
Definition at line 484 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.getDiaSourcesInRegion | ( | self, | |
pixel_ranges, | |||
dt, | |||
return_pandas = False |
|||
) |
Returns catalog of DiaSource instances from given region. Sources are searched based on pixelization index and region is determined by the set of indices. There is no assumption on a particular type of index, client is responsible for consistency when calculating pixelization indices. This method returns :doc:`/modules/lsst.afw.table/index` catalog with schema determined by the schema of PPDB table. Re-mapping of the column names is done for some columns (based on column map passed to constructor) but types or units are not changed. Parameters ---------- pixel_ranges : `list` of `tuple` Sequence of ranges, range is a tuple (minPixelID, maxPixelID). This defines set of pixel indices to be included in result. dt : `datetime.datetime` Time of the current visit return_pandas : `bool` Return a `pandas.DataFrame` instead of `lsst.afw.table.SourceCatalog`. Returns ------- catalog : `lsst.afw.table.SourceCatalog`, `pandas.DataFrame`, or `None` Catalog containing DiaSource records. `None` is returned if ``read_sources_months`` configuration parameter is set to 0.
Definition at line 425 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.isVisitProcessed | ( | self, | |
visitInfo | |||
) |
Test whether data from an image has been loaded into the database. Used as part of ap_verify metrics. Parameters ---------- visitInfo : `lsst.afw.image.VisitInfo` The metadata for the image of interest. Returns ------- isProcessed : `bool` `True` if the data are present, `False` otherwise.
Definition at line 802 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.lastVisit | ( | self | ) |
Returns last visit information or `None` if visits table is empty. Visits table is used by ap_proto to track visit information, it is not a part of the regular PPDB schema. Returns ------- visit : `Visit` or `None` Last stored visit info or `None` if there was nothing stored yet.
Definition at line 268 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.makeSchema | ( | self, | |
drop = False , |
|||
mysql_engine = 'InnoDB' , |
|||
oracle_tablespace = None , |
|||
oracle_iot = False |
|||
) |
Create or re-create all tables. Parameters ---------- drop : `bool` If True then drop tables before creating new ones. mysql_engine : `str`, optional Name of the MySQL engine to use for new tables. oracle_tablespace : `str`, optional Name of Oracle tablespace. oracle_iot : `bool`, optional Make Index-organized DiaObjectLast table.
def lsst.dax.ppdb.ppdb.Ppdb.saveVisit | ( | self, | |
visitId, | |||
visitTime | |||
) |
def lsst.dax.ppdb.ppdb.Ppdb.storeDiaForcedSources | ( | self, | |
sources | |||
) |
Store a set of DIAForcedSources from current visit. This methods takes :doc:`/modules/lsst.afw.table/index` catalog, its schema must be compatible with the schema of L1 database table: - column names must correspond to database table columns - some columns names may be re-mapped based on column map passed to constructor - types and units of the columns must match database definitions, no unit conversion is performed presently - columns that have default values in database schema can be omitted from afw schema Parameters ---------- sources : `lsst.afw.table.BaseCatalog` or `pandas.DataFrame` Catalog containing DiaForcedSource records
Definition at line 748 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.storeDiaObjects | ( | self, | |
objs, | |||
dt | |||
) |
Store catalog of DiaObjects from current visit. This methods takes :doc:`/modules/lsst.afw.table/index` catalog, its schema must be compatible with the schema of PPDB table: - column names must correspond to database table columns - some columns names are re-mapped based on column map passed to constructor - types and units of the columns must match database definitions, no unit conversion is performed presently - columns that have default values in database schema can be omitted from afw schema - this method knows how to fill interval-related columns (validityStart, validityEnd) they do not need to appear in afw schema Parameters ---------- objs : `lsst.afw.table.BaseCatalog` or `pandas.DataFrame` Catalog with DiaObject records dt : `datetime.datetime` Time of the visit
Definition at line 608 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.storeDiaSources | ( | self, | |
sources | |||
) |
Store catalog of DIASources from current visit. This methods takes :doc:`/modules/lsst.afw.table/index` catalog, its schema must be compatible with the schema of L1 database table: - column names must correspond to database table columns - some columns names may be re-mapped based on column map passed to constructor - types and units of the columns must match database definitions, no unit conversion is performed presently - columns that have default values in database schema can be omitted from afw schema Parameters ---------- sources : `lsst.afw.table.BaseCatalog` or `pandas.DataFrame` Catalog containing DiaSource records
Definition at line 717 of file ppdb.py.
def lsst.dax.ppdb.ppdb.Ppdb.tableRowCount | ( | self | ) |
Returns dictionary with the table names and row counts. Used by ``ap_proto`` to keep track of the size of the database tables. Depending on database technology this could be expensive operation. Returns ------- row_counts : `dict` Dict where key is a table name and value is a row count.
Definition at line 321 of file ppdb.py.